Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

The extension attribute kogitobusinesskey is not taken into account for intermediate events #3282

Closed
andleosab opened this issue Nov 15, 2023 · 2 comments
Assignees

Comments

@andleosab
Copy link

Describe the bug

When sending a message for the intermediate message element to consume, the event dispatcher can't match it:

2023-11-14 19:17:45.575 DEBUG 27935 --- [ntainer#0-0-C-1] o.k.k.s.e.impl.DefaultEventUnmarshaller : Converting event with payload {"id":"51e2b192-b4fe-46ab-8923-e506b65b9649","source":"notification-svc","type":"vendorFileLocationMessage","time":"2023-11-14T14:04:17.298369-08:00","data":{"location":"s3://bucket/file-832555"},"specversion":"1.0","kogitobusinesskey":"order-832555","kogitoprocessinstanceid":"236945bc-6363-4eb5-86c4-9e6c2e7246dd"} to class class org.kie.kogito.event.process.ProcessDataEvent

2023-11-14 19:17:45.576 INFO 27935 --- [ntainer#0-0-C-1] o.k.k.s.e.impl.ProcessEventDispatcher : No matches found for trigger vendorFileLocationMessage in process sub-Process. Skipping consumed message ProcessDataEvent{kogitoProcessInstanceVersion='null', kogitoParentProcessInstanceId='null', kogitoProcessInstanceState='null', kogitoReferenceId='null', kogitoStartFromNode='null', kogitoBusinessKey='order-832555', kogitoProcessType='null'} AbstractDataEvent{specVersion=1.0, id='51e2b192-b4fe-46ab-8923-e506b65b9649', source=notification-svc, type='vendorFileLocationMessage', time=2023-11-14T22:04:17.298369Z, subject='null', dataContentType='null', dataSchema=null, data=VendorFileLocationEvent [location=s3://bucket/file-832555], kogitoProcessInstanceId='null', kogitoRootProcessInstanceId='null', kogitoProcessId='null', kogitoRootProcessId='null', kogitoAddons='null', extensionAttributes={kogitoprocessinstanceid=236945bc-6363-4eb5-86c4-9e6c2e7246dd}}

Expected behavior

should be able to resume the process/subprocess using kogitobusinesskey attribute in the cloud event.
Example:

{
"id": "51e2b192-b4fe-46ab-8923-e506b65b9649",
"source": "",
"type": "vendorFileLocationMessage",
"time": "2023-11-14T14:04:17.298369-08:00",
"data": {
"location": "s3://bucket/file-832555"
},
"specversion": "1.0",
"kogitobusinesskey": "order-832555"
}

Actual behavior

event recognized but not dispatched to respective intermediate message element in process or subprocess.

How to Reproduce?

  1. have a process (subprocess?) with intermediate message element:
  2. Start process with a businessKey included
  3. use that buisiness Key to resume the process by sending a message similar to below through Kafka:

{
"id": "51e2b192-b4fe-46ab-8923-e506b65b9649",
"source": "",
"type": "vendorFileLocationMessage",
"time": "2023-11-14T14:04:17.298369-08:00",
"data": {
"location": "s3://bucket/file-832555"
},
"specversion": "1.0",
"kogitobusinesskey": "order-832555"
}

Output of uname -a or ver

No response

Output of java -version

No response

GraalVM version (if different from Java)

No response

Kogito version or git rev (or at least Quarkus version if you are using Kogito via Quarkus platform BOM)

No response

Build tool (ie. output of mvnw --version or gradlew --version)

No response

Additional information

No response

@andleosab
Copy link
Author

Kogito version tested 1.27.0

@fjtirado fjtirado self-assigned this Feb 6, 2024
@fjtirado
Copy link
Contributor

Will be fixed with https://issues.redhat.com/browse/KOGITO-9276
There will be a follow up issue for improving peromance #3413

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants