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

…events (apache#3455)
kiegroup · Aug 5, 2024 · fae9c67 · fae9c67
1 parent 189c7be
commit fae9c67
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;