This is an automated email from the ASF dual-hosted git repository.
pefernan pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-kie-kogito-runtimes.git
The following commit(s) were added to refs/heads/main by this push:
new fd652ba48d [incubator-kie-kogito-runtimes-issue#4191]
NotificationEventPublisher… (#4192)
fd652ba48d is described below
commit fd652ba48d77f1d5de4b9db0b2e0f2dc8b160711
Author: abhijithumbe <[email protected]>
AuthorDate: Mon Feb 16 15:45:36 2026 +0530
[incubator-kie-kogito-runtimes-issue#4191] NotificationEventPublisher…
(#4192)
* [incubator-kie-kogito-runtimes-issue#4191] NotificationEventPublisher
update to checks an event prefixed with UserTaskInstanceDeadline
* [incubator-kie-kogito-runtimes-issue#4191] NotificationEventPublisher
update to checks an event prefixed with UserTaskInstanceDeadline
---------
Co-authored-by: abhijithumbe <[email protected]>
---
.../kogito/task/notification/quarkus/NotificationEventPublisher.java | 2 +-
.../kie/kogito/quarkus/common/deployment/KogitoAssetsProcessor.java | 4 ++--
.../task/notification/spring/SpringNotificationEventPublisher.java | 2 +-
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/quarkus/addons/task-notification/runtime/src/main/java/org/kie/kogito/task/notification/quarkus/NotificationEventPublisher.java
b/quarkus/addons/task-notification/runtime/src/main/java/org/kie/kogito/task/notification/quarkus/NotificationEventPublisher.java
index 1984f5cded..5d256101fa 100644
---
a/quarkus/addons/task-notification/runtime/src/main/java/org/kie/kogito/task/notification/quarkus/NotificationEventPublisher.java
+++
b/quarkus/addons/task-notification/runtime/src/main/java/org/kie/kogito/task/notification/quarkus/NotificationEventPublisher.java
@@ -42,7 +42,7 @@ public class NotificationEventPublisher implements
EventPublisher {
@Override
public void publish(DataEvent<?> event) {
- if (event.getType().startsWith("UserTaskDeadline")) {
+ if (event.getType().startsWith("UserTaskInstanceDeadline")) {
logger.debug("About to publish event {} to topic {}", event,
CHANNEL_NAME);
try {
emitter.send(event);
diff --git
a/quarkus/extensions/kogito-quarkus-extension-common/kogito-quarkus-common-deployment/src/main/java/org/kie/kogito/quarkus/common/deployment/KogitoAssetsProcessor.java
b/quarkus/extensions/kogito-quarkus-extension-common/kogito-quarkus-common-deployment/src/main/java/org/kie/kogito/quarkus/common/deployment/KogitoAssetsProcessor.java
index a4879226ea..9a1f38d414 100644
---
a/quarkus/extensions/kogito-quarkus-extension-common/kogito-quarkus-common-deployment/src/main/java/org/kie/kogito/quarkus/common/deployment/KogitoAssetsProcessor.java
+++
b/quarkus/extensions/kogito-quarkus-extension-common/kogito-quarkus-common-deployment/src/main/java/org/kie/kogito/quarkus/common/deployment/KogitoAssetsProcessor.java
@@ -367,8 +367,8 @@ public class KogitoAssetsProcessor {
new ReflectiveClassBuildItem(true, true,
"org.kie.kogito.services.event.UserTaskInstanceDataEvent"));
reflectiveClass.produce(
new ReflectiveClassBuildItem(true, true,
"org.kie.kogito.services.event.impl.UserTaskInstanceEventBody"));
- reflectiveClass.produce(new ReflectiveClassBuildItem(true, true,
"org.kie.kogito.services.event.UserTaskDeadlineDataEvent"));
- reflectiveClass.produce(new ReflectiveClassBuildItem(true, true,
"org.kie.kogito.services.event.impl.UserTaskDeadlineEventBody"));
+ reflectiveClass.produce(new ReflectiveClassBuildItem(true, true,
"org.kie.kogito.event.usertask.UserTaskInstanceDeadlineDataEvent"));
+ reflectiveClass.produce(new ReflectiveClassBuildItem(true, true,
"org.kie.kogito.event.usertask.UserTaskInstanceDeadlineEventBody"));
if (context.getAddonsConfig().useMonitoring()) {
registerMonitoringAddonClasses(reflectiveClass);
diff --git
a/springboot/addons/task-notification/src/main/java/org/kie/kogito/task/notification/spring/SpringNotificationEventPublisher.java
b/springboot/addons/task-notification/src/main/java/org/kie/kogito/task/notification/spring/SpringNotificationEventPublisher.java
index 0994174638..2aa756ebd8 100644
---
a/springboot/addons/task-notification/src/main/java/org/kie/kogito/task/notification/spring/SpringNotificationEventPublisher.java
+++
b/springboot/addons/task-notification/src/main/java/org/kie/kogito/task/notification/spring/SpringNotificationEventPublisher.java
@@ -42,7 +42,7 @@ public class SpringNotificationEventPublisher implements
EventPublisher {
@Override
public void publish(DataEvent<?> event) {
- if (event.getType().startsWith("UserTaskDeadline")) {
+ if (event.getType().startsWith("UserTaskInstanceDeadline")) {
logger.debug("About to publish event {} to Kafka topic {}", event,
topic);
try {
emitter.send(topic, event);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
