You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2018/02/01 12:31:37 UTC
[camel] 02/03: Upgrade reactive stuff
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7dcb03eab62c6c860b0afee4b9afe6661d9917c1
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Feb 1 13:23:41 2018 +0100
Upgrade reactive stuff
---
.../apache/camel/component/reactor/engine/ReactorCamelProcessor.java | 4 ++--
parent/pom.xml | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/components/camel-reactor/src/main/java/org/apache/camel/component/reactor/engine/ReactorCamelProcessor.java b/components/camel-reactor/src/main/java/org/apache/camel/component/reactor/engine/ReactorCamelProcessor.java
index d3c270f..3c02e0d 100644
--- a/components/camel-reactor/src/main/java/org/apache/camel/component/reactor/engine/ReactorCamelProcessor.java
+++ b/components/camel-reactor/src/main/java/org/apache/camel/component/reactor/engine/ReactorCamelProcessor.java
@@ -32,7 +32,7 @@ import reactor.core.publisher.EmitterProcessor;
import reactor.core.publisher.Flux;
import reactor.core.publisher.FluxSink;
import reactor.core.publisher.SynchronousSink;
-import reactor.util.concurrent.QueueSupplier;
+import reactor.util.concurrent.Queues;
final class ReactorCamelProcessor implements Closeable {
private final String name;
@@ -86,7 +86,7 @@ final class ReactorCamelProcessor implements Closeable {
flux = flux.handle(this::onItemEmitted).onBackpressureLatest();
} else {
// Default strategy is BUFFER
- flux = flux.onBackpressureBuffer(QueueSupplier.SMALL_BUFFER_SIZE, this::onBackPressure).handle(this::onItemEmitted);
+ flux = flux.onBackpressureBuffer(Queues.SMALL_BUFFER_SIZE, this::onBackPressure).handle(this::onItemEmitted);
}
flux.subscribe(this.publisher);
diff --git a/parent/pom.xml b/parent/pom.xml
index 921a547..2a0f889 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -575,8 +575,8 @@
<quartz2-version>2.3.0</quartz2-version>
<quickfixj-version>2.0.0</quickfixj-version>
<rabbitmq-amqp-client-version>5.1.2</rabbitmq-amqp-client-version>
- <reactive-streams-version>1.0.0</reactive-streams-version>
- <reactor-version>3.0.7.RELEASE</reactor-version>
+ <reactive-streams-version>1.0.2</reactive-streams-version>
+ <reactor-version>3.1.3.RELEASE</reactor-version>
<reflections-version>0.9.11</reflections-version>
<reflections-bundle-version>0.9.11_1</reflections-bundle-version>
<regexp-bundle-version>1.4_1</regexp-bundle-version>
--
To stop receiving notification emails like this one, please contact
davsclaus@apache.org.