This is an automated email from the ASF dual-hosted git repository. rcordier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit d3ae4a1f1b2f8e6aad8ab7f247c8eb4cb594f703 Author: Benoit Tellier <[email protected]> AuthorDate: Mon May 4 18:03:02 2020 +0700 JAMES-3149 ReactorElasticSearchClient should not call subscribeOn Do call `publishOn` instead like in `CassandraAsyncExecutor` --- .../java/org/apache/james/backends/es/ReactorElasticSearchClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/ReactorElasticSearchClient.java b/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/ReactorElasticSearchClient.java index 4885b08..1636df6 100644 --- a/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/ReactorElasticSearchClient.java +++ b/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/ReactorElasticSearchClient.java @@ -154,7 +154,7 @@ public class ReactorElasticSearchClient implements AutoCloseable { private static <T> Mono<T> toReactor(Consumer<ActionListener<T>> async) { return Mono.<T>create(sink -> async.accept(getListener(sink))) - .subscribeOn(Schedulers.elastic()); + .publishOn(Schedulers.elastic()); } private static <T> ActionListener<T> getListener(MonoSink<T> sink) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
