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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
