[james-project] 07/21: JAMES-3081 make the rabbitmq mailqueue messages persistent

[rcordier]

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 6021556175d1a5dfde8fae04780ac1e476cdb9aa
Author: Rémi KOWALSKI <rkowal...@linagora.com>
AuthorDate: Mon Mar 2 10:14:30 2020 +0100

    JAMES-3081 make the rabbitmq mailqueue messages persistent
---
 .../src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java  | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
 
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
index 4e0485c..06bb328 100644
--- 
a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
+++ 
b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/Enqueuer.java
@@ -19,6 +19,7 @@
 
 package org.apache.james.queue.rabbitmq;
 
+import static com.rabbitmq.client.MessageProperties.PERSISTENT_TEXT_PLAIN;
 import static org.apache.james.backends.rabbitmq.Constants.EMPTY_ROUTING_KEY;
 import static org.apache.james.queue.api.MailQueue.ENQUEUED_METRIC_NAME_PREFIX;
 
@@ -38,6 +39,7 @@ import org.apache.mailet.Mail;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.github.fge.lambdas.Throwing;
+import com.rabbitmq.client.AMQP;
 
 import reactor.core.publisher.Mono;
 import reactor.rabbitmq.OutboundMessage;
@@ -83,9 +85,16 @@ class Enqueuer {
     }
 
     private Mono<EnqueuedItem> publishReferenceToRabbit(MailReference 
mailReference) throws MailQueue.MailQueueException {
+        AMQP.BasicProperties basicProperties = new 
AMQP.BasicProperties.Builder()
+            .deliveryMode(PERSISTENT_TEXT_PLAIN.getDeliveryMode())
+            .priority(PERSISTENT_TEXT_PLAIN.getPriority())
+            .contentType(PERSISTENT_TEXT_PLAIN.getContentType())
+            .build();
+
         OutboundMessage data = new OutboundMessage(
             name.toRabbitExchangeName().asString(),
             EMPTY_ROUTING_KEY,
+            basicProperties,
             getMailReferenceBytes(mailReference));
         return sender.send(Mono.just(data))
             .then(Mono.just(


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org