This is an automated email from the ASF dual-hosted git repository. aduprat pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 2338e6461779ec114a9eb13f1da887a2f6030a64 Author: Matthieu Baechler <matth...@apache.org> AuthorDate: Fri Feb 15 14:26:33 2019 +0100 JAMES-2817 GroupRegistration deliver doesn't need to use subscribeWith --- .../main/java/org/apache/james/mailbox/events/GroupRegistration.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java index c704ad3..8d477e7 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupRegistration.java @@ -40,7 +40,6 @@ import com.rabbitmq.client.Connection; import reactor.core.Disposable; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; -import reactor.core.publisher.MonoProcessor; import reactor.core.scheduler.Schedulers; import reactor.rabbitmq.AcknowledgableDelivery; import reactor.rabbitmq.BindingSpecification; @@ -143,9 +142,7 @@ class GroupRegistration implements Registration { .publishOn(Schedulers.elastic()) .flatMap(any -> Mono.fromRunnable(Throwing.runnable(() -> runListener(event)))) .onErrorResume(throwable -> retryHandler.handleRetry(event, currentRetryCount, throwable)) - .then(Mono.fromRunnable(acknowledgableDelivery::ack)) - .subscribeWith(MonoProcessor.create()) - .then(); + .then(Mono.fromRunnable(acknowledgableDelivery::ack)); } Mono<Void> reDeliver(Event event) { --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org