[james-project] 02/04: MAILBOX-396 Use elastic scheduler in CassandraMailQueueBrowser.browseReferences

[matthieu]

This is an automated email from the ASF dual-hosted git repository.

matthieu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 35272085ae338053208bfe2e856167ace46e0490
Author: Rémi KOWALSKI <rkowal...@linagora.com>
AuthorDate: Thu Jan 30 10:05:40 2020 +0100

    MAILBOX-396 Use elastic scheduler in 
CassandraMailQueueBrowser.browseReferences
---
 .../james/queue/rabbitmq/view/cassandra/CassandraMailQueueBrowser.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueBrowser.java
 
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueBrowser.java
index 166d956..31e448c 100644
--- 
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueBrowser.java
+++ 
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueBrowser.java
@@ -111,7 +111,7 @@ public class CassandraMailQueueBrowser {
         return browseStartDao.findBrowseStart(queueName)
             .flatMapMany(this::allSlicesStartingAt)
             .flatMapSequential(slice -> browseSlice(queueName, slice))
-            .subscribeOn(Schedulers.parallel());
+            .subscribeOn(Schedulers.elastic());
     }
 
     private Mono<Mail> toMailFuture(EnqueuedItemWithSlicingContext 
enqueuedItemWithSlicingContext) {


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org