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
