MAILBOX-374 Checking registration queues deletion should filter out group queues
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/8935b9c1 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/8935b9c1 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/8935b9c1 Branch: refs/heads/master Commit: 8935b9c1243117caf9701678814c9a6c9f745372 Parents: 255f1be Author: Benoit Tellier <btell...@linagora.com> Authored: Fri Jan 18 11:43:57 2019 +0700 Committer: Benoit Tellier <btell...@linagora.com> Committed: Tue Jan 22 17:07:15 2019 +0700 ---------------------------------------------------------------------- .../java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/8935b9c1/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java ---------------------------------------------------------------------- diff --git a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java index 8784493..efe5296 100644 --- a/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java +++ b/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java @@ -34,6 +34,7 @@ import static org.apache.james.mailbox.events.EventBusTestFixture.MailboxListene import static org.apache.james.mailbox.events.EventBusTestFixture.NO_KEYS; import static org.apache.james.mailbox.events.EventBusTestFixture.WAIT_CONDITION; import static org.apache.james.mailbox.events.EventBusTestFixture.newListener; +import static org.apache.james.mailbox.events.GroupRegistration.WorkQueueName.MAILBOX_EVENT_WORK_QUEUE_PREFIX; import static org.apache.james.mailbox.events.RabbitMQEventBus.MAILBOX_EVENT; import static org.apache.james.mailbox.events.RabbitMQEventBus.MAILBOX_EVENT_EXCHANGE_NAME; import static org.assertj.core.api.Assertions.assertThat; @@ -414,6 +415,7 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract, eventBus3.stop(); assertThat(rabbitManagementAPI.listQueues()) + .filteredOn(queue -> !queue.getName().startsWith(MAILBOX_EVENT_WORK_QUEUE_PREFIX)) .isEmpty(); } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
