[camel-quarkus] branch camel-master updated: Fix reactive streams

[gnodet]

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 <gno...@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(),