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 cf71fddc2b972bd0b7ec227db940afe7d2f42708
Author: Gautier DI FOLCO <[email protected]>
AuthorDate: Fri Mar 6 13:40:40 2020 +0100

    JAMES-3103 Set EventBus' queue to autoDelete in order to avoid leak
---
 .../java/org/apache/james/mailbox/events/KeyRegistrationHandler.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 49ea9b9..20c4b4a 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
@@ -99,7 +99,7 @@ class KeyRegistrationHandler {
         sender.declareQueue(QueueSpecification.queue(eventBusId.asString())
             .durable(DURABLE)
             .exclusive(!EXCLUSIVE)
-            .autoDelete(!AUTO_DELETE)
+            .autoDelete(AUTO_DELETE)
             .arguments(NO_ARGUMENTS))
             .map(AMQP.Queue.DeclareOk::getQueue)
             .retryBackoff(retryBackoff.getMaxRetries(), 
retryBackoff.getFirstBackoff(), FOREVER, retryBackoff.getJitterFactor())


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to