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 b98f4cf57c26550f24d7d67c89f60f02fa2a8c53 Author: Benoit Tellier <[email protected]> AuthorDate: Mon May 25 18:09:44 2020 +0700 JAMES-3191 Specify the scheduler unregistration should be run on --- .../java/org/apache/james/mailbox/events/KeyRegistrationHandler.java | 1 + 1 file changed, 1 insertion(+) diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java index 1d5fdd9..5add858 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/KeyRegistrationHandler.java @@ -133,6 +133,7 @@ class KeyRegistrationHandler { if (registration.unregister().lastListenerRemoved()) { registrationBinder.unbind(key) .retryWhen(Retry.backoff(retryBackoff.getMaxRetries(), retryBackoff.getFirstBackoff()).jitter(retryBackoff.getJitterFactor()).scheduler(Schedulers.elastic())) + .subscribeOn(Schedulers.elastic()) .block(); } })); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
