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 bce3f3839f788517f25580618f8c0e9980641773
Author: Rémi KOWALSKI <rkowal...@linagora.com>
AuthorDate: Thu Nov 14 14:02:03 2019 +0100
JAMES-2979 fix delivery runnable mail dequeue
---
.../james/transport/mailets/remote/delivery/DeliveryRunnable.java | 3 +--
1 file changed, 1 insertion(+), 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 1699174..a6d92d0 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
@@ -84,8 +84,7 @@ public class DeliveryRunnable implements Disposable {
public void start() {
remoteDeliveryScheduler =
Schedulers.newBoundedElastic(Schedulers.DEFAULT_BOUNDED_ELASTIC_SIZE,
Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE, "RemoteDelivery");
disposable = Flux.from(queue.deQueue())
- .publishOn(remoteDeliveryScheduler)
- .flatMap(this::runStep)
+ .flatMap(queueItem ->
runStep(queueItem).subscribeOn(remoteDeliveryScheduler))
.onErrorContinue(((throwable, nothing) -> LOGGER.error("Exception
caught in RemoteDelivery", throwable)))
.subscribeOn(remoteDeliveryScheduler)
.subscribe();
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org
