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 f39bea91362791401898b8579b718fe72421afee Author: Rémi KOWALSKI <[email protected]> AuthorDate: Mon Mar 2 11:19:03 2020 +0100 JAMES-3082 set eventbus rabbitmq messages persitent --- .../main/java/org/apache/james/mailbox/events/EventDispatcher.java | 4 ++++ .../main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java index 93b1028..239d716 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventDispatcher.java @@ -19,6 +19,7 @@ package org.apache.james.mailbox.events; +import static com.rabbitmq.client.MessageProperties.PERSISTENT_TEXT_PLAIN; import static org.apache.james.backends.rabbitmq.Constants.DIRECT_EXCHANGE; import static org.apache.james.backends.rabbitmq.Constants.DURABLE; import static org.apache.james.mailbox.events.RabbitMQEventBus.EVENT_BUS_ID; @@ -64,6 +65,9 @@ class EventDispatcher { this.localListenerRegistry = localListenerRegistry; this.basicProperties = new AMQP.BasicProperties.Builder() .headers(ImmutableMap.of(EVENT_BUS_ID, eventBusId.asString())) + .deliveryMode(PERSISTENT_TEXT_PLAIN.getDeliveryMode()) + .priority(PERSISTENT_TEXT_PLAIN.getPriority()) + .contentType(PERSISTENT_TEXT_PLAIN.getContentType()) .build(); this.mailboxListenerExecutor = mailboxListenerExecutor; } diff --git a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java index f1933ad..8286d30 100644 --- a/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java +++ b/mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/GroupConsumerRetry.java @@ -19,6 +19,7 @@ package org.apache.james.mailbox.events; +import static com.rabbitmq.client.MessageProperties.PERSISTENT_TEXT_PLAIN; import static org.apache.james.backends.rabbitmq.Constants.DIRECT_EXCHANGE; import static org.apache.james.backends.rabbitmq.Constants.DURABLE; import static org.apache.james.backends.rabbitmq.Constants.EMPTY_ROUTING_KEY; @@ -118,6 +119,9 @@ class GroupConsumerRetry { EMPTY_ROUTING_KEY, new AMQP.BasicProperties.Builder() .headers(ImmutableMap.of(RETRY_COUNT, currentRetryCount + 1)) + .deliveryMode(PERSISTENT_TEXT_PLAIN.getDeliveryMode()) + .priority(PERSISTENT_TEXT_PLAIN.getPriority()) + .contentType(PERSISTENT_TEXT_PLAIN.getContentType()) .build(), eventAsBytes)); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
