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 2c4bdc9d33 kie-kogito-runtimes-3521: Align jobs service knative
eventing http connector config with runtime events config (#3522)
2c4bdc9d33 is described below
commit 2c4bdc9d33ba37dc583f73d8c4697b5b56f1bae4
Author: Walter Medvedeo <[email protected]>
AuthorDate: Fri May 17 12:34:26 2024 +0200
kie-kogito-runtimes-3521: Align jobs service knative eventing http
connector config with runtime events config (#3522)
---
.../jobs/knative/eventing/quarkus/KnativeEventingJobsService.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/quarkus/addons/jobs/knative-eventing/runtime/src/main/java/org/kie/kogito/jobs/knative/eventing/quarkus/KnativeEventingJobsService.java
b/quarkus/addons/jobs/knative-eventing/runtime/src/main/java/org/kie/kogito/jobs/knative/eventing/quarkus/KnativeEventingJobsService.java
index f445b3bf8a..a7bb8bc485 100644
---
a/quarkus/addons/jobs/knative-eventing/runtime/src/main/java/org/kie/kogito/jobs/knative/eventing/quarkus/KnativeEventingJobsService.java
+++
b/quarkus/addons/jobs/knative-eventing/runtime/src/main/java/org/kie/kogito/jobs/knative/eventing/quarkus/KnativeEventingJobsService.java
@@ -24,6 +24,7 @@ import org.eclipse.microprofile.config.inject.ConfigProperty;
import org.eclipse.microprofile.reactive.messaging.Channel;
import org.eclipse.microprofile.reactive.messaging.Emitter;
import org.eclipse.microprofile.reactive.messaging.Message;
+import org.eclipse.microprofile.reactive.messaging.OnOverflow;
import
org.kie.kogito.addon.quarkus.common.reactive.messaging.http.CloudEventHttpOutgoingDecorator;
import
org.kie.kogito.jobs.messaging.quarkus.AbstractReactiveMessagingJobsService;
@@ -43,7 +44,7 @@ public class KnativeEventingJobsService extends
AbstractReactiveMessagingJobsSer
public KnativeEventingJobsService(
@ConfigProperty(name = "kogito.service.url") URI serviceUrl,
ObjectMapper objectMapper,
- @Channel(KOGITO_JOB_SERVICE_JOB_REQUEST_EVENTS_CHANNEL)
Emitter<String> eventsEmitter) {
+ @Channel(KOGITO_JOB_SERVICE_JOB_REQUEST_EVENTS_CHANNEL)
@OnOverflow(value = OnOverflow.Strategy.UNBOUNDED_BUFFER) Emitter<String>
eventsEmitter) {
super(serviceUrl, objectMapper, eventsEmitter);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
