dfiai commented on issue #3337: URL: https://github.com/apache/incubator-kie-kogito-runtimes/issues/3337#issuecomment-1867161608
> @dfiai Two consumers with the same trigger is not necessarily an issue Moreover, you are experiencing unexpected behaviour even if you use a different event, so lets focus on that second scenario. With the SWF that Ricardo attached, can you provide the complete log? application.properties ```application.properties mp.messaging.outgoing.out-wait.connector=smallrye-kafka mp.messaging.outgoing.out-wait.value.serializer=org.apache.kafka.common.serialization.StringSerializer mp.messaging.outgoing.out-wait.topic=wait mp.messaging.outgoing.out-wait.group.id=kogito-sw-callback mp.messaging.outgoing.out-wait.auto.offset.reset=earliest mp.messaging.incoming.in-resume.connector=smallrye-kafka mp.messaging.incoming.in-resume.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer mp.messaging.incoming.in-resume.topic=resume mp.messaging.incoming.in-resume.group.id=kogito-sw-callback mp.messaging.incoming.in-resume.auto.offset.reset=earliest mp.messaging.incoming.wait.connector=smallrye-kafka mp.messaging.incoming.wait.topic=wait mp.messaging.incoming.wait.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer mp.messaging.incoming.wait.group.id=kogito-sw-callback mp.messaging.incoming.wait.auto.offset.reset=earliest mp.messaging.outgoing.resume.connector=smallrye-kafka mp.messaging.outgoing.resume.topic=resume mp.messaging.outgoing.resume.value.serializer=org.apache.kafka.common.serialization.StringSerializer mp.messaging.outgoing.resume.group.id=kogito-sw-callback mp.messaging.outgoing.resume.auto.offset.reset=earliest mp.messaging.incoming.wait2.connector=smallrye-kafka mp.messaging.incoming.wait2.topic=wait mp.messaging.incoming.wait2.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer mp.messaging.incoming.wait2.group.id=kogito-sw-callback mp.messaging.incoming.wait2.auto.offset.reset=earliest mp.messaging.outgoing.resume2.connector=smallrye-kafka mp.messaging.outgoing.resume2.topic=resume mp.messaging.outgoing.resume2.value.serializer=org.apache.kafka.common.serialization.StringSerializer mp.messaging.outgoing.resume2.group.id=kogito-sw-callback mp.messaging.outgoing.resume2.auto.offset.reset=earliest ``` You can find logs for Ricardo's SWF bellow. Attempting various configurations, the case process consistently fails to complete. Regardless of the approach taken, the process either remains incomplete, or the process states are unexpectedly triggered only for the initial event. ```log 2023-12-22T09:33:27,445 | INFO | Consumer for wait2 started thread=Quarkus Main Thread module=or.ki.ko.ev.im.AbstractMessageConsumer 2023-12-22T09:33:27,447 | INFO | Consumer for wait started thread=Quarkus Main Thread module=or.ki.ko.ev.im.AbstractMessageConsumer 2023-12-22T09:33:27,452 | INFO | Registered Kogito CloudEvent extension thread=Quarkus Main Thread module=or.ki.ko.ad.qu.me.co.QuarkusKogitoExtensionInitializer 2023-12-22T09:33:27,594 | INFO | kogito-template 0.0.1-SNAPSHOT on JVM (powered by Quarkus 2.16.7.Final) started in 9.323s. Listening on: http://localhost:8080 thread=Quarkus Main Thread module=io.quarkus 2023-12-22T09:33:27,594 | INFO | Profiles local,base activated. Live Coding activated. thread=Quarkus Main Thread module=io.quarkus 2023-12-22T09:33:27,594 | INFO | Installed features: [cache, cdi, grpc-server, infinispan-client, jackson-jq, kafka-client, kogito-addon-events-process-extension, kogito-addon-messaging-extension, kogito-addon-persistence-infinispan-extension, kogito-serverless-workflow, kotlin, kubernetes-client, openshift-client, qute, reactive-routes, rest-client, rest-client-jackson, resteasy, resteasy-jackson, smallrye-context-propagation, smallrye-health, smallrye-openapi, smallrye-reactive-messaging, smallrye-reactive-messaging-http, smallrye-reactive-messaging-kafka, swagger-ui, vertx] thread=Quarkus Main Thread module=io.quarkus 2023-12-22T09:33:32,094 | INFO | Starting workflow 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=executor-thread-0 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:32,097 | INFO | Triggered node 'Start' for process 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=executor-thread-0 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:32,099 | INFO | Triggered node 'waitForEvent' for process 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=executor-thread-0 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:32,100 | INFO | Triggered node 'resumeEvent' for process 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=executor-thread-0 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:32,121 | DEBUG | publishing event AbstractDataEvent{specVersion=1.0, id='b282ee4e-0320-49a0-af98-a11af29bd0fc', source=/process/callback, type='resume', time=2023-12-22T09:33:32.109332950+07:00, subject='null', dataContentType='null', dataSchema=null, data={"move":"This is the initial data in the model"}, kogitoProcessInstanceId='947ecac7-19bf-4373-89a8-23b464a0e3e8', kogitoRootProcessInstanceId='null', kogitoProcessId='callback', kogitoRootProcessId='null', kogitoAddons='null', kogitoIdentity='null', extensionAttributes={kogitoproctype=SW, kogitoprocinstanceid=947ecac7-19bf-4373-89a8-23b464a0e3e8, kogitoprocist=Active, kogitoprocversion=1.0, kogitoprocid=callback}} thread=executor-thread-0 module=or.ki.ko.ad.qu.me.co.AbstractQuarkusCloudEventEmitter 2023-12-22T09:33:32,144 | INFO | Triggered node 'waitEvent' for process 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=executor-thread-0 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:32,146 | INFO | Workflow 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) was started, now 'Active' thread=executor-thread-0 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:32,263 | DEBUG | Emitter kogito-processinstances-events is not ready to send messages thread=executor-thread-0 module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:32,282 | DEBUG | About to publish event AbstractDataEvent{specVersion=1.0, id='a9650e25-f64e-4aeb-b4fc-0e9bb049729e', source=/callback, type='ProcessInstanceEvent', time=2023-12-22T09:33:32.261780839+07:00, subject='null', dataContentType='application/json', dataSchema=null, data=ProcessInstanceEventBody{id='947ecac7-19bf-4373-89a8-23b464a0e3e8', version='1.0', parentInstanceId='null', rootInstanceId='null', processId='callback', processType='null', rootProcessId='null', processName='Workflow Callback example', startDate=Fri Dec 22 09:33:32 ICT 2023, endDate=null, state=1, businessKey='null', nodeInstances=[NodeInstance [id=f46ab1f0-9c77-486d-aa67-125ee11e3cbe, nodeId=3, nodeName=waitForEvent, nodeType=CompositeContextNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=null], NodeInstance [id=48c1afae-c947-4afd-ba36-90a401180123, nodeId=9, nodeName=waitEvent, nodeType=EventNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=null], NodeInstance [id=0027 2d3b-be18-4e7e-89d2-e8d4b230f15c, nodeId=7, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023], NodeInstance [id=422984f1-a00c-411b-9853-a5836fe53a93, nodeId=6, nodeName=resumeEvent, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023], NodeInstance [id=c9a94b89-8892-4bac-9d8e-932f12770da8, nodeId=4, nodeName=EmbeddedStart, nodeType=StartNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023], NodeInstance [id=0b48d594-f873-41f1-8f4a-6534261a13ff, nodeId=1, nodeName=Start, nodeType=StartNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023]], variables={workflowdata={}}, error=null, roles=null, milestones=[], identity=null}, kogitoProcessInstanceId='947ecac7-19bf-4373-89a8-23b464a0e3e8', kogitoRootProcessInstanceId='null', kogitoProcessId='callback', kogitoRootProcessId='null', kogitoAddons='infinispan -persistence,cloudevents', kogitoIdentity='null', extensionAttributes={kogitoprocinstanceid=947ecac7-19bf-4373-89a8-23b464a0e3e8, kogitoprocist=1, kogitoprocversion=1.0, kogitoprocid=callback, kogitoaddons=infinispan-persistence,cloudevents}} to topic kogito-processinstances-events thread=executor-thread-0 module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:32,311 | DEBUG | Event payload '{"id":"a9650e25-f64e-4aeb-b4fc-0e9bb049729e","source":"/callback","type":"ProcessInstanceEvent","time":"2023-12-22T09:33:32.261780839+07:00","data":{"id":"947ecac7-19bf-4373-89a8-23b464a0e3e8","version":"1.0","parentInstanceId":null,"rootInstanceId":null,"processId":"callback","processType":null,"rootProcessId":null,"processName":"Workflow Callback example","startDate":"2023-12-22T09:33:32.095+07:00","endDate":null,"state":1,"businessKey":null,"nodeInstances":[{"id":"f46ab1f0-9c77-486d-aa67-125ee11e3cbe","nodeId":"3","nodeDefinitionId":"_jbpm-unique-2","nodeName":"waitForEvent","nodeType":"CompositeContextNode","triggerTime":"2023-12-22T09:33:32.099+07:00","leaveTime":null},{"id":"48c1afae-c947-4afd-ba36-90a401180123","nodeId":"9","nodeDefinitionId":"_jbpm-unique-6","nodeName":"waitEvent","nodeType":"EventNode","triggerTime":"2023-12-22T09:33:32.144+07:00","leaveTime":null},{"id":"00272d3b-be18-4e7e-89d2-e8d4b230f15c","nodeId":"7"," nodeDefinitionId":"_jbpm-unique-5","nodeName":"Script","nodeType":"ActionNode","triggerTime":"2023-12-22T09:33:32.142+07:00","leaveTime":"2023-12-22T09:33:32.143+07:00"},{"id":"422984f1-a00c-411b-9853-a5836fe53a93","nodeId":"6","nodeDefinitionId":"_jbpm-unique-4","nodeName":"resumeEvent","nodeType":"ActionNode","triggerTime":"2023-12-22T09:33:32.100+07:00","leaveTime":"2023-12-22T09:33:32.142+07:00"},{"id":"c9a94b89-8892-4bac-9d8e-932f12770da8","nodeId":"4","nodeDefinitionId":"_jbpm-unique-3","nodeName":"EmbeddedStart","nodeType":"StartNode","triggerTime":"2023-12-22T09:33:32.099+07:00","leaveTime":"2023-12-22T09:33:32.100+07:00"},{"id":"0b48d594-f873-41f1-8f4a-6534261a13ff","nodeId":"1","nodeDefinitionId":"_jbpm-unique-0","nodeName":"Start","nodeType":"StartNode","triggerTime":"2023-12-22T09:33:32.097+07:00","leaveTime":"2023-12-22T09:33:32.098+07:00"}],"variables":{"workflowdata":{}},"error":null,"roles":null,"milestones":[],"identity":null},"specversion":"1.0","datacontenttype":" application/json","kogitoprocinstanceid":"947ecac7-19bf-4373-89a8-23b464a0e3e8","kogitoprocid":"callback","kogitoaddons":"infinispan-persistence,cloudevents","kogitoprocversion":"1.0","kogitoprocist":"1"}' thread=executor-thread-0 module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:32,317 | DEBUG | Successfully published event AbstractDataEvent{specVersion=1.0, id='a9650e25-f64e-4aeb-b4fc-0e9bb049729e', source=/callback, type='ProcessInstanceEvent', time=2023-12-22T09:33:32.261780839+07:00, subject='null', dataContentType='application/json', dataSchema=null, data=ProcessInstanceEventBody{id='947ecac7-19bf-4373-89a8-23b464a0e3e8', version='1.0', parentInstanceId='null', rootInstanceId='null', processId='callback', processType='null', rootProcessId='null', processName='Workflow Callback example', startDate=Fri Dec 22 09:33:32 ICT 2023, endDate=null, state=1, businessKey='null', nodeInstances=[NodeInstance [id=f46ab1f0-9c77-486d-aa67-125ee11e3cbe, nodeId=3, nodeName=waitForEvent, nodeType=CompositeContextNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=null], NodeInstance [id=48c1afae-c947-4afd-ba36-90a401180123, nodeId=9, nodeName=waitEvent, nodeType=EventNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=null], NodeInstance [i d=00272d3b-be18-4e7e-89d2-e8d4b230f15c, nodeId=7, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023], NodeInstance [id=422984f1-a00c-411b-9853-a5836fe53a93, nodeId=6, nodeName=resumeEvent, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023], NodeInstance [id=c9a94b89-8892-4bac-9d8e-932f12770da8, nodeId=4, nodeName=EmbeddedStart, nodeType=StartNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023], NodeInstance [id=0b48d594-f873-41f1-8f4a-6534261a13ff, nodeId=1, nodeName=Start, nodeType=StartNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:32 ICT 2023]], variables={workflowdata={}}, error=null, roles=null, milestones=[], identity=null}, kogitoProcessInstanceId='947ecac7-19bf-4373-89a8-23b464a0e3e8', kogitoRootProcessInstanceId='null', kogitoProcessId='callback', kogitoRootProcessId='null', kogitoAddons='infi nispan-persistence,cloudevents', kogitoIdentity='null', extensionAttributes={kogitoprocinstanceid=947ecac7-19bf-4373-89a8-23b464a0e3e8, kogitoprocist=1, kogitoprocversion=1.0, kogitoprocid=callback, kogitoaddons=infinispan-persistence,cloudevents}} to topic kogito-processinstances-events thread=kafka-producer-network-thread | kafka-producer-kogito-processinstances-events module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:56,543 | INFO | SRMSG18256: Initialize record store for topic-partition 'resume-0' at position 27. thread=vert.x-eventloop-thread-4 module=io.sm.re.me.kafka 2023-12-22T09:33:56,566 | INFO | SRMSG18256: Initialize record store for topic-partition 'wait-0' at position 27. thread=vert.x-eventloop-thread-5 module=io.sm.re.me.kafka 2023-12-22T09:33:56,567 | DEBUG | Received message io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord@4c53c508 thread=vert.x-eventloop-thread-5 module=or.ki.ko.ad.qu.me.co.AbstractQuarkusCloudEventReceiver 2023-12-22T09:33:56,570 | DEBUG | Received message with reference id '947ecac7-19bf-4373-89a8-23b464a0e3e8' going to use it to send signal 'wait' thread=kogito-event-executor-1 module=or.ki.ko.ev.im.ProcessEventDispatcher 2023-12-22T09:33:56,625 | INFO | Triggered node 'waitForEvent 2' for process 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=kogito-event-executor-1 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:56,625 | INFO | Triggered node 'resumeEvent2' for process 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=kogito-event-executor-1 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:56,626 | DEBUG | publishing event AbstractDataEvent{specVersion=1.0, id='eead7a43-ada0-435a-9a20-21b92d67f408', source=/process/callback, type='resume2', time=2023-12-22T09:33:56.626566759+07:00, subject='null', dataContentType='null', dataSchema=null, data={"move":"This is the initial data in the model"}, kogitoProcessInstanceId='947ecac7-19bf-4373-89a8-23b464a0e3e8', kogitoRootProcessInstanceId='', kogitoProcessId='callback', kogitoRootProcessId='', kogitoAddons='null', kogitoIdentity='null', extensionAttributes={kogitobusinesskey=, kogitoparentprociid=, kogitorootprocid=, kogitoprocrefid=, kogitoproctype=SW, kogitoprocinstanceid=947ecac7-19bf-4373-89a8-23b464a0e3e8, kogitoprocist=Active, kogitoprocversion=1.0, kogitorootprociid=, kogitoprocid=callback}} thread=kogito-event-executor-1 module=or.ki.ko.ad.qu.me.co.AbstractQuarkusCloudEventEmitter 2023-12-22T09:33:56,627 | INFO | Triggered node 'waitEvent2' for process 'callback' (947ecac7-19bf-4373-89a8-23b464a0e3e8) thread=kogito-event-executor-1 module=or.ki.ko.se.wo.de.DevModeServerlessWorkflowLogger 2023-12-22T09:33:56,632 | DEBUG | Emitter kogito-processinstances-events is not ready to send messages thread=kogito-event-executor-1 module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:56,632 | DEBUG | About to publish event AbstractDataEvent{specVersion=1.0, id='efd64f2e-08c5-414b-bac1-d5fa85ab9000', source=/callback, type='ProcessInstanceEvent', time=2023-12-22T09:33:56.632264625+07:00, subject='null', dataContentType='application/json', dataSchema=null, data=ProcessInstanceEventBody{id='947ecac7-19bf-4373-89a8-23b464a0e3e8', version='1.0', parentInstanceId='', rootInstanceId='', processId='callback', processType='null', rootProcessId='', processName='Workflow Callback example', startDate=Fri Dec 22 09:33:32 ICT 2023, endDate=null, state=1, businessKey='', nodeInstances=[NodeInstance [id=9ee4f93d-ace8-4284-a87d-f29077f4d916, nodeId=15, nodeName=waitForEvent 2, nodeType=CompositeContextNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=null], NodeInstance [id=22b9e074-1fb1-400c-819e-c525aed6b89d, nodeId=21, nodeName=waitEvent2, nodeType=EventNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=null], NodeInstance [id=886a792d-cc54-4 cbf-99cd-0aa8dd972a1c, nodeId=19, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=23644016-1fda-4440-be68-5518fd85cbc6, nodeId=18, nodeName=resumeEvent2, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=00bb3ebc-4f87-4ec6-a8a7-915c450afa30, nodeId=16, nodeName=EmbeddedStart, nodeType=StartNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=f46ab1f0-9c77-486d-aa67-125ee11e3cbe, nodeId=3, nodeName=waitForEvent, nodeType=CompositeContextNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=b44f83f8-9d3a-4240-a3c3-8618b6be65be, nodeId=12, nodeName=EmbeddedEnd, nodeType=EndNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=91dd52c6-dd26-46f8-aabc-2c33cc110415, nodeId=11, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=039cb9e4-2839-4290-8d5c-4bb0d86e84d8, nodeId=10, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=48c1afae-c947-4afd-ba36-90a401180123, nodeId=9, nodeName=waitEvent, nodeType=EventNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023]], variables={workflowdata={"move":"This is the initial data in the model and has been modified by the event publisher"}}, error=null, roles=null, milestones=[], identity=null}, kogitoProcessInstanceId='947ecac7-19bf-4373-89a8-23b464a0e3e8', kogitoRootProcessInstanceId='', kogitoProcessId='callback', kogitoRootProcessId='', kogitoAddons='infinispan-persistence,cloudevents', kogitoIdentity='null', extensionAttributes={kogitorootprocid=, kogitoparentprociid=, kogitoprocinstanceid=947ecac7-19bf-4373- 89a8-23b464a0e3e8, kogitoprocist=1, kogitoprocversion=1.0, kogitorootprociid=, kogitoprocid=callback, kogitoaddons=infinispan-persistence,cloudevents}} to topic kogito-processinstances-events thread=kogito-event-executor-1 module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:56,634 | DEBUG | Received message io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord@122027f7 thread=vert.x-eventloop-thread-5 module=or.ki.ko.ad.qu.me.co.AbstractQuarkusCloudEventReceiver 2023-12-22T09:33:56,635 | DEBUG | Event payload '{"id":"efd64f2e-08c5-414b-bac1-d5fa85ab9000","source":"/callback","type":"ProcessInstanceEvent","time":"2023-12-22T09:33:56.632264625+07:00","data":{"id":"947ecac7-19bf-4373-89a8-23b464a0e3e8","version":"1.0","parentInstanceId":"","rootInstanceId":"","processId":"callback","processType":null,"rootProcessId":"","processName":"Workflow Callback example","startDate":"2023-12-22T09:33:32.095+07:00","endDate":null,"state":1,"businessKey":"","nodeInstances":[{"id":"9ee4f93d-ace8-4284-a87d-f29077f4d916","nodeId":"15","nodeDefinitionId":"_jbpm-unique-12","nodeName":"waitForEvent 2","nodeType":"CompositeContextNode","triggerTime":"2023-12-22T09:33:56.625+07:00","leaveTime":null},{"id":"22b9e074-1fb1-400c-819e-c525aed6b89d","nodeId":"21","nodeDefinitionId":"_jbpm-unique-16","nodeName":"waitEvent2","nodeType":"EventNode","triggerTime":"2023-12-22T09:33:56.628+07:00","leaveTime":null},{"id":"886a792d-cc54-4cbf-99cd-0aa8dd972a1c","nodeId":"19"," nodeDefinitionId":"_jbpm-unique-15","nodeName":"Script","nodeType":"ActionNode","triggerTime":"2023-12-22T09:33:56.627+07:00","leaveTime":"2023-12-22T09:33:56.627+07:00"},{"id":"23644016-1fda-4440-be68-5518fd85cbc6","nodeId":"18","nodeDefinitionId":"_jbpm-unique-14","nodeName":"resumeEvent2","nodeType":"ActionNode","triggerTime":"2023-12-22T09:33:56.626+07:00","leaveTime":"2023-12-22T09:33:56.627+07:00"},{"id":"00bb3ebc-4f87-4ec6-a8a7-915c450afa30","nodeId":"16","nodeDefinitionId":"_jbpm-unique-13","nodeName":"EmbeddedStart","nodeType":"StartNode","triggerTime":"2023-12-22T09:33:56.625+07:00","leaveTime":"2023-12-22T09:33:56.625+07:00"},{"id":"f46ab1f0-9c77-486d-aa67-125ee11e3cbe","nodeId":"3","nodeDefinitionId":"_jbpm-unique-2","nodeName":"waitForEvent","nodeType":"CompositeContextNode","triggerTime":"2023-12-22T09:33:32.099+07:00","leaveTime":"2023-12-22T09:33:56.625+07:00"},{"id":"b44f83f8-9d3a-4240-a3c3-8618b6be65be","nodeId":"12","nodeDefinitionId":"_jbpm-unique-9","nodeName":" EmbeddedEnd","nodeType":"EndNode","triggerTime":"2023-12-22T09:33:56.624+07:00","leaveTime":"2023-12-22T09:33:56.624+07:00"},{"id":"91dd52c6-dd26-46f8-aabc-2c33cc110415","nodeId":"11","nodeDefinitionId":"_jbpm-unique-8","nodeName":"Script","nodeType":"ActionNode","triggerTime":"2023-12-22T09:33:56.623+07:00","leaveTime":"2023-12-22T09:33:56.624+07:00"},{"id":"039cb9e4-2839-4290-8d5c-4bb0d86e84d8","nodeId":"10","nodeDefinitionId":"_jbpm-unique-7","nodeName":"Script","nodeType":"ActionNode","triggerTime":"2023-12-22T09:33:56.621+07:00","leaveTime":"2023-12-22T09:33:56.623+07:00"},{"id":"48c1afae-c947-4afd-ba36-90a401180123","nodeId":"9","nodeDefinitionId":"_jbpm-unique-6","nodeName":"waitEvent","nodeType":"EventNode","triggerTime":"2023-12-22T09:33:32.144+07:00","leaveTime":"2023-12-22T09:33:56.621+07:00"}],"variables":{"workflowdata":{"move":"This is the initial data in the model and has been modified by the event publisher"}},"error":null,"roles":null,"milestones":[],"identity":null },"specversion":"1.0","datacontenttype":"application/json","kogitoprocinstanceid":"947ecac7-19bf-4373-89a8-23b464a0e3e8","kogitoprocid":"callback","kogitoaddons":"infinispan-persistence,cloudevents","kogitoprocversion":"1.0","kogitoprocist":"1"}' thread=kogito-event-executor-1 module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:56,635 | DEBUG | Acking message io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord@4c53c508 thread=kogito-event-executor-1 module=or.ki.ko.ad.qu.me.co.AbstractQuarkusCloudEventReceiver 2023-12-22T09:33:56,636 | DEBUG | Received message with reference id '947ecac7-19bf-4373-89a8-23b464a0e3e8' going to use it to send signal 'wait' thread=kogito-event-executor-1 module=or.ki.ko.ev.im.ProcessEventDispatcher 2023-12-22T09:33:56,637 | DEBUG | Successfully published event AbstractDataEvent{specVersion=1.0, id='efd64f2e-08c5-414b-bac1-d5fa85ab9000', source=/callback, type='ProcessInstanceEvent', time=2023-12-22T09:33:56.632264625+07:00, subject='null', dataContentType='application/json', dataSchema=null, data=ProcessInstanceEventBody{id='947ecac7-19bf-4373-89a8-23b464a0e3e8', version='1.0', parentInstanceId='', rootInstanceId='', processId='callback', processType='null', rootProcessId='', processName='Workflow Callback example', startDate=Fri Dec 22 09:33:32 ICT 2023, endDate=null, state=1, businessKey='', nodeInstances=[NodeInstance [id=9ee4f93d-ace8-4284-a87d-f29077f4d916, nodeId=15, nodeName=waitForEvent 2, nodeType=CompositeContextNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=null], NodeInstance [id=22b9e074-1fb1-400c-819e-c525aed6b89d, nodeId=21, nodeName=waitEvent2, nodeType=EventNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=null], NodeInstance [id=886a792d- cc54-4cbf-99cd-0aa8dd972a1c, nodeId=19, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=23644016-1fda-4440-be68-5518fd85cbc6, nodeId=18, nodeName=resumeEvent2, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=00bb3ebc-4f87-4ec6-a8a7-915c450afa30, nodeId=16, nodeName=EmbeddedStart, nodeType=StartNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=f46ab1f0-9c77-486d-aa67-125ee11e3cbe, nodeId=3, nodeName=waitForEvent, nodeType=CompositeContextNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=b44f83f8-9d3a-4240-a3c3-8618b6be65be, nodeId=12, nodeName=EmbeddedEnd, nodeType=EndNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=91dd52c6-dd26-46f8-aabc-2c33cc110415, node Id=11, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=039cb9e4-2839-4290-8d5c-4bb0d86e84d8, nodeId=10, nodeName=Script, nodeType=ActionNode, triggerTime=Fri Dec 22 09:33:56 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023], NodeInstance [id=48c1afae-c947-4afd-ba36-90a401180123, nodeId=9, nodeName=waitEvent, nodeType=EventNode, triggerTime=Fri Dec 22 09:33:32 ICT 2023, leaveTime=Fri Dec 22 09:33:56 ICT 2023]], variables={workflowdata={"move":"This is the initial data in the model and has been modified by the event publisher"}}, error=null, roles=null, milestones=[], identity=null}, kogitoProcessInstanceId='947ecac7-19bf-4373-89a8-23b464a0e3e8', kogitoRootProcessInstanceId='', kogitoProcessId='callback', kogitoRootProcessId='', kogitoAddons='infinispan-persistence,cloudevents', kogitoIdentity='null', extensionAttributes={kogitorootprocid=, kogitoparentprociid=, kogitoprocinstanceid=947ecac7-19bf -4373-89a8-23b464a0e3e8, kogitoprocist=1, kogitoprocversion=1.0, kogitorootprociid=, kogitoprocid=callback, kogitoaddons=infinispan-persistence,cloudevents}} to topic kogito-processinstances-events thread=kafka-producer-network-thread | kafka-producer-kogito-processinstances-events module=or.ki.ko.ev.pr.ReactiveMessagingEventPublisher 2023-12-22T09:33:56,641 | DEBUG | Acking message io.smallrye.reactive.messaging.kafka.IncomingKafkaRecord@122027f7 thread=kogito-event-executor-1 module=or.ki.ko.ad.qu.me.co.AbstractQuarkusCloudEventReceiver ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
