This is an automated email from the ASF dual-hosted git repository. rcordier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit c6e63d908bca438411f5c7db6b05e990356b2325 Author: Benoit Tellier <[email protected]> AuthorDate: Mon Jun 14 15:09:37 2021 +0700 JAMES-3599 GroupRegistration : nack is blocking Thus it should be scheduled on the elastic scheduler --- .../main/java/org/apache/james/events/GroupRegistration.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/event-bus/distributed/src/main/java/org/apache/james/events/GroupRegistration.java b/event-bus/distributed/src/main/java/org/apache/james/events/GroupRegistration.java index 57839ef..5b5ce39 100644 --- a/event-bus/distributed/src/main/java/org/apache/james/events/GroupRegistration.java +++ b/event-bus/distributed/src/main/java/org/apache/james/events/GroupRegistration.java @@ -121,11 +121,7 @@ class GroupRegistration implements Registration { .durable(DURABLE) .exclusive(!EXCLUSIVE) .autoDelete(!AUTO_DELETE) - .arguments(deadLetterQueue(namingStrategy.deadLetterExchange())), - BindingSpecification.binding() - .exchange(namingStrategy.exchange()) - .queue(queueName.asString()) - .routingKey(EMPTY_ROUTING_KEY)); + .arguments(deadLetterQueue(namingStrategy.deadLetterExchange()))); } private Disposable consumeWorkQueue() { @@ -148,7 +144,9 @@ class GroupRegistration implements Registration { .then(Mono.<Void>fromRunnable(acknowledgableDelivery::ack).subscribeOn(Schedulers.elastic()))) .onErrorResume(e -> { LOGGER.error("Unable to process delivery for group {}", group, e); - return Mono.fromRunnable(() -> acknowledgableDelivery.nack(!REQUEUE)); + return Mono.fromRunnable(() -> acknowledgableDelivery.nack(!REQUEUE)) + .subscribeOn(Schedulers.elastic()) + .then(); }); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
