[Fix apache#3453] Setting overflow strategy to unbounded for process …

…events
fjtirado · Mar 22, 2024 · 1b1589c · 1b1589c
1 parent ded2b68
commit 1b1589c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/.../runtime/src/main/java/org/kie/kogito/events/process/ReactiveMessagingEventPublisher.java b/.../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;