You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gn...@apache.org on 2020/04/07 13:08:24 UTC
[camel-quarkus] branch camel-master updated: Fix reactive streams
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/camel-master by this push:
new 9fc92b0 Fix reactive streams
9fc92b0 is described below
commit 9fc92b0f035ac272b40feb30bab2b0ac544f87e2
Author: Guillaume Nodet <gn...@gmail.com>
AuthorDate: Tue Apr 7 15:07:58 2020 +0200
Fix reactive streams
---
.../component/reactive/streams/ReactiveStreamsRecorder.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/extensions/reactive-streams/runtime/src/main/java/org/apache/camel/quarkus/component/reactive/streams/ReactiveStreamsRecorder.java b/extensions/reactive-streams/runtime/src/main/java/org/apache/camel/quarkus/component/reactive/streams/ReactiveStreamsRecorder.java
index 677c798..9b2b597 100644
--- a/extensions/reactive-streams/runtime/src/main/java/org/apache/camel/quarkus/component/reactive/streams/ReactiveStreamsRecorder.java
+++ b/extensions/reactive-streams/runtime/src/main/java/org/apache/camel/quarkus/component/reactive/streams/ReactiveStreamsRecorder.java
@@ -25,6 +25,7 @@ import org.apache.camel.component.reactive.streams.ReactiveStreamsComponent;
import org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsService;
import org.apache.camel.component.reactive.streams.api.CamelReactiveStreamsServiceFactory;
import org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsServiceFactory;
+import org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration;
import org.apache.camel.support.service.ServiceHelper;
@Recorder
@@ -63,6 +64,13 @@ public class ReactiveStreamsRecorder {
@Override
public CamelReactiveStreamsService getReactiveStreamsService() {
synchronized (this.lock) {
+ if (getReactiveStreamsEngineConfiguration() == null) {
+ ReactiveStreamsEngineConfiguration reactiveStreamsEngineConfiguration = new ReactiveStreamsEngineConfiguration();
+ reactiveStreamsEngineConfiguration.setThreadPoolMaxSize(getThreadPoolMaxSize());
+ reactiveStreamsEngineConfiguration.setThreadPoolMinSize(getThreadPoolMinSize());
+ reactiveStreamsEngineConfiguration.setThreadPoolName(getThreadPoolName());
+ setReactiveStreamsEngineConfiguration(reactiveStreamsEngineConfiguration);
+ }
if (reactiveStreamService == null) {
this.reactiveStreamService = reactiveStreamServiceFactory.newInstance(
getCamelContext(),