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 bt...@apache.org on 2019/11/20 07:32:15 UTC
[james-project] 32/41: JAMES-2979 fix spooler mail dequeue
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 438bb45b76690dce5467fd3a12393ca3ea8e1934
Author: Rémi KOWALSKI <rk...@linagora.com>
AuthorDate: Thu Nov 14 14:01:46 2019 +0100
JAMES-2979 fix spooler mail dequeue
---
.../java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java b/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java
index e2101d1..2bd7ed0 100644
--- a/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java
+++ b/server/mailet/mailetcontainer-camel/src/main/java/org/apache/james/mailetcontainer/impl/JamesMailSpooler.java
@@ -107,8 +107,7 @@ public class JamesMailSpooler implements Disposable, Configurable, MailSpoolerMB
LOGGER.info("Queue={}", queue);
disposable = Flux.from(queue.deQueue())
- .publishOn(spooler)
- .flatMap(this::handleOnQueueItem)
+ .flatMap(item -> handleOnQueueItem(item).subscribeOn(spooler))
.onErrorContinue((throwable, item) -> LOGGER.error("Exception processing mail while spooling {}", item, throwable))
.subscribeOn(Schedulers.boundedElastic())
.subscribe();
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org