This is an automated email from the ASF dual-hosted git repository.
fjtiradosarti 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 f4821b9f4d [Fix #3453] Setting overflow strategy to unbounded for
process events (#3455)
f4821b9f4d is described below
commit f4821b9f4dcc38e7a2df33fef383ddea4c3cd487
Author: Francisco Javier Tirado Sarti
<[email protected]>
AuthorDate: Mon Apr 1 13:51:36 2024 +0200
[Fix #3453] Setting overflow strategy to unbounded for process events
(#3455)
---
.../org/kie/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 2eb517d5d8..c232a1eb47 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 java.util.function.BiConsumer;
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;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
