fixup! JAMES-2489 Use RabbitMQAPI Delete Queue for cleanup
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/aa86dfed Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/aa86dfed Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/aa86dfed Branch: refs/heads/master Commit: aa86dfed2310c1aa3757e08ece0127ed1098d574 Parents: 7dad760 Author: Benoit Tellier <[email protected]> Authored: Thu Nov 1 11:26:08 2018 +0700 Committer: Benoit Tellier <[email protected]> Committed: Thu Nov 1 11:26:08 2018 +0700 ---------------------------------------------------------------------- .../james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/aa86dfed/server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/RabbitMqMailQueueFactoryTest.java ---------------------------------------------------------------------- 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 4e7a414..8a71cec 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 @@ -54,6 +54,7 @@ class RabbitMqMailQueueFactoryTest implements MailQueueFactoryContract<RabbitMQM static final RabbitMQExtension rabbitMQExtension = new RabbitMQExtension(); private RabbitMQMailQueueFactory mailQueueFactory; + private RabbitMQManagementApi mqManagementApi; @BeforeEach void setup() throws URISyntaxException { @@ -78,13 +79,13 @@ class RabbitMqMailQueueFactoryTest implements MailQueueFactoryContract<RabbitMQM BLOB_ID_FACTORY, mailQueueViewFactory, Clock.systemUTC()); - RabbitMQManagementApi mqManagementApi = new RabbitMQManagementApi(rabbitMQConfiguration); + mqManagementApi = new RabbitMQManagementApi(rabbitMQConfiguration); mailQueueFactory = new RabbitMQMailQueueFactory(rabbitClient, mqManagementApi, factory); } @AfterEach - void tearDown(DockerRabbitMQ rabbitMQ) throws Exception { - rabbitMQ.reset(); + void tearDown() { + mqManagementApi.deleteAllQueues(); } @Override --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
