This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch exchange-factory in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2dbbf050d5ef9221f6d76736c0cbeacb51344fc0 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Feb 22 10:01:27 2021 +0100 CAMEL-16222: PooledExchangeFactory experiment --- .../camel/component/reactive/streams/ReactiveStreamsConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsConsumer.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsConsumer.java index 989b901..815c3e2 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsConsumer.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsConsumer.java @@ -75,7 +75,7 @@ public class ReactiveStreamsConsumer extends DefaultConsumer { public void onComplete() { if (endpoint.isForwardOnComplete()) { - Exchange exchange = endpoint.createExchange(); + Exchange exchange = createExchange(true); exchange.getIn().setHeader(ReactiveStreamsConstants.REACTIVE_STREAMS_EVENT_TYPE, "onComplete"); doSend(exchange, done -> { @@ -85,7 +85,7 @@ public class ReactiveStreamsConsumer extends DefaultConsumer { public void onError(Throwable error) { if (endpoint.isForwardOnError()) { - Exchange exchange = endpoint.createExchange(); + Exchange exchange = createExchange(true); exchange.getIn().setHeader(ReactiveStreamsConstants.REACTIVE_STREAMS_EVENT_TYPE, "onError"); exchange.getIn().setBody(error);
