fjtirado opened a new issue, #1457: URL: https://github.com/apache/incubator-kie-issues/issues/1457
[EventPublisher ](https://github.com/apache/incubator-kie-kogito-runtimes/blob/main/api/kogito-api/src/main/java/org/kie/kogito/event/EventPublisher.java#L51)has the list of events generated at the end of a [UnitOfWork](https://github.com/apache/incubator-kie-kogito-runtimes/blob/main/api/kogito-api/src/main/java/org/kie/kogito/uow/UnitOfWork.java#L41) These events are currently sent one by one by [ReactiveEventMessagePublisher](https://github.com/apache/incubator-kie-kogito-runtimes/blob/main/quarkus/addons/events/process/runtime/src/main/java/org/kie/kogito/events/process/ReactiveMessagingEventPublisher.java#L167), which is the case of Http Smallrye connector heavily affects system throughput, which in turn increase memory consumption because of event queuing. One possible improvement is to set the message body to the entire collection, minimizing the number of external calls. However this will affect consumers. For example, in DataIndex, [ReactiveMessageEventConsumer ](https://github.com/apache/incubator-kie-kogito-apps/blob/main/data-index/data-index-service/data-index-service-common/src/main/java/org/kie/kogito/index/service/messaging/ReactiveMessagingEventConsumer.java#L56) will have to be changed to check if the message body contains one event or a collection of them. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
