From fae9c6741fe06b8fbe59efc6ee68f08fb0543a7c Mon Sep 17 00:00:00 2001
From: Francisco Javier Tirado Sarti
 <65240126+fjtirado@users.noreply.github.com>
Date: Mon, 1 Apr 2024 13:51:36 +0200
Subject: [PATCH] [Fix #3453] Setting overflow strategy to unbounded for
 process events (#3455)

---
 .../kogito/events/process/ReactiveMessagingEventPublisher.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/quarkus/addons/events/process/runtime/src/main/java/org/kie/kogito/events/process/ReactiveMessagingEventPublisher.java b/quarkus/addons/events/process/runtime/src/main/java/org/kie/kogito/events/process/ReactiveMessagingEventPublisher.java
index 2eb517d5d81..c232a1eb471 100644
--- a/quarkus/addons/events/process/runtime/src/main/java/org/kie/kogito/events/process/ReactiveMessagingEventPublisher.java
+++ b/quarkus/addons/events/process/runtime/src/main/java/org/kie/kogito/events/process/ReactiveMessagingEventPublisher.java
@@ -25,6 +25,8 @@
 
 import org.eclipse.microprofile.reactive.messaging.Channel;
 import org.eclipse.microprofile.reactive.messaging.Message;
+import org.eclipse.microprofile.reactive.messaging.OnOverflow;
+import org.eclipse.microprofile.reactive.messaging.OnOverflow.Strategy;
 import org.kie.kogito.addon.quarkus.common.reactive.messaging.MessageDecoratorProvider;
 import org.kie.kogito.event.DataEvent;
 import org.kie.kogito.event.EventPublisher;
@@ -52,6 +54,7 @@ public class ReactiveMessagingEventPublisher implements EventPublisher {
 
     @Inject
     @Channel(PROCESS_INSTANCES_TOPIC_NAME)
+    @OnOverflow(Strategy.UNBOUNDED_BUFFER)
     MutinyEmitter<String> processInstancesEventsEmitter;
     private BiConsumer<MutinyEmitter<String>, Message<String>> processInstanceConsumer;