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 3b9efc5fd464d95f10cfd3938b148b0203f84e8d Author: Benoit Tellier <[email protected]> AuthorDate: Fri May 31 15:32:49 2019 +0700 JAMES-2733 DeliveryRunnable fails upon acknowledging queue elements --- .../james/transport/mailets/remote/delivery/DeliveryRunnable.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java b/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java index d9ffc8c..5ec4ec0 100644 --- a/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java +++ b/server/mailet/mailets/src/main/java/org/apache/james/transport/mailets/remote/delivery/DeliveryRunnable.java @@ -41,6 +41,7 @@ import com.google.common.annotations.VisibleForTesting; import reactor.core.Disposable; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; +import reactor.core.scheduler.Scheduler; import reactor.core.scheduler.Schedulers; public class DeliveryRunnable implements Disposable { @@ -80,11 +81,12 @@ public class DeliveryRunnable implements Disposable { } public void start() { + Scheduler remoteDeliveryScheduler = Schedulers.newElastic("RemoteDelivery"); disposable = Flux.from(queue.deQueue()) - .publishOn(Schedulers.newParallel("RemoteDelivery", configuration.getWorkersThreadCount())) + .publishOn(remoteDeliveryScheduler) .flatMap(this::runStep) .onErrorContinue(((throwable, nothing) -> LOGGER.error("Exception caught in RemoteDelivery", throwable))) - .subscribeOn(Schedulers.elastic()) + .subscribeOn(remoteDeliveryScheduler) .subscribe(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
