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 c342b13ff2acfd72472caee66d4164717fc02115 Author: Benoit Tellier <[email protected]> AuthorDate: Tue Sep 22 12:21:34 2020 +0700 JAMES-3305 MailQueue creation should not fail when no dead-letter set up --- .../rabbitmq/RabbitMqMailQueueFactoryTest.java | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java index ecf5c1c..a028e99 100644 --- a/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java +++ b/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java @@ -19,6 +19,10 @@ package org.apache.james.queue.rabbitmq; +import static org.apache.james.backends.rabbitmq.Constants.AUTO_DELETE; +import static org.apache.james.backends.rabbitmq.Constants.DURABLE; +import static org.apache.james.backends.rabbitmq.Constants.EXCLUSIVE; +import static org.assertj.core.api.Assertions.assertThatCode; import static org.mockito.ArgumentMatchers.any; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; @@ -38,8 +42,11 @@ import org.apache.james.queue.rabbitmq.view.api.MailQueueView; import org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueBrowser; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.RegisterExtension; +import reactor.rabbitmq.QueueSpecification; + class RabbitMqMailQueueFactoryTest implements MailQueueFactoryContract<RabbitMQMailQueue> { private static final HashBlobId.Factory BLOB_ID_FACTORY = new HashBlobId.Factory(); @@ -87,4 +94,19 @@ class RabbitMqMailQueueFactoryTest implements MailQueueFactoryContract<RabbitMQM return mailQueueFactory; } + @Test + void getQueueShouldNotFailWhenTheQueueExistsWithoutDeadLetterSetUp() { + rabbitMQExtension.getSender() + .declareQueue(QueueSpecification.queue("JamesMailQueue-workqueue-" + NAME_1.asString()) + .durable(DURABLE) + .exclusive(!EXCLUSIVE) + .autoDelete(!AUTO_DELETE)) + .block(); + + mailQueueFactory.createQueue(NAME_1); + + assertThatCode(() -> mailQueueFactory.getQueue(NAME_1)) + .doesNotThrowAnyException(); + } + } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
