You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by ma...@apache.org on 2020/02/13 08:48:47 UTC
[james-project] 02/04: MAILBOX-396 Use elastic scheduler in
CassandraMailQueueBrowser.browseReferences
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 <rk...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org