You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by ka...@apache.org on 2022/09/01 20:07:40 UTC
[james-project] 02/02: JAMES-3810 Decrease slice browsing concurrency
This is an automated email from the ASF dual-hosted git repository.
kao pushed a commit to branch 3.7.x
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit b727dec24b4997ac4b353ec789e5ff8bf26e552f
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Mon Aug 22 23:25:29 2022 +0700
JAMES-3810 Decrease slice browsing concurrency
flatMapIterable processes 256 items in parallel which is likely to
be too much when browsing slices of 1h of email traffic.
Decrease this to a more reasonable value.
(cherry picked from commit f463bf9c07196545a506a8229f934721369bf601)
---
.../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 94314de05d..64f85be0b1 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
@@ -134,7 +134,7 @@ public class CassandraMailQueueBrowser {
Flux<EnqueuedItemWithSlicingContext> browseReferences(MailQueueName queueName, Instant browseStart) {
return allSlicesStartingAt(browseStart)
- .flatMapSequential(slice -> browseSlice(queueName, slice));
+ .flatMapSequential(slice -> browseSlice(queueName, slice), 4);
}
private Mono<Pair<EnqueuedItem, Mail>> toMailFuture(EnqueuedItemWithSlicingContext enqueuedItemWithSlicingContext) {
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org