MAILBOX-374 Also test EventBus behaviour when confronted with RabbitMQ restarts
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/aa452a1f Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/aa452a1f Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/aa452a1f Branch: refs/heads/master Commit: aa452a1f7be7a1f616a8d0bf14a3d1273945d1c3 Parents: 7ab8c67 Author: Benoit Tellier <btell...@linagora.com> Authored: Thu Jan 24 16:27:36 2019 +0700 Committer: Benoit Tellier <btell...@linagora.com> Committed: Fri Jan 25 10:33:25 2019 +0700 ---------------------------------------------------------------------- .../mailbox/events/RabbitMQEventBusTest.java | 50 ++++++++++++++++++++ 1 file changed, 50 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/aa452a1f/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 2137610..38ca6c5 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 @@ -324,6 +324,56 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract, } @Test + void dispatchShouldWorkAfterRestartForOldRegistration() throws Exception { + eventBus.start(); + MailboxListener listener = newListener(); + eventBus.register(listener, GROUP_A); + + rabbitMQExtension.getRabbitMQ().restart(); + + eventBus.dispatch(EVENT, NO_KEYS).block(); + verify(listener, after(THIRTY_SECONDS).times(1)).event(EVENT); + } + + @Test + void dispatchShouldWorkAfterRestartForNewRegistration() throws Exception { + eventBus.start(); + MailboxListener listener = newListener(); + + rabbitMQExtension.getRabbitMQ().restart(); + + eventBus.register(listener, GROUP_A); + + eventBus.dispatch(EVENT, NO_KEYS).block(); + verify(listener, after(THIRTY_SECONDS).times(1)).event(EVENT); + } + + @Test + void dispatchShouldWorkAfterRestartForOldKeyRegistration() throws Exception { + eventBus.start(); + MailboxListener listener = newListener(); + eventBus.register(listener, KEY_1); + + rabbitMQExtension.getRabbitMQ().restart(); + + eventBus.dispatch(EVENT, KEY_1).block(); + verify(listener, after(THIRTY_SECONDS).times(1)).event(EVENT); + } + + @Test + void dispatchShouldWorkAfterRestartForNewKeyRegistration() throws Exception { + eventBus.start(); + MailboxListener listener = newListener(); + + rabbitMQExtension.getRabbitMQ().restart(); + + eventBus.register(listener, KEY_1); + + eventBus.dispatch(EVENT, KEY_1).block(); + verify(listener, after(THIRTY_SECONDS).times(1)).event(EVENT); + } + + @Test void dispatchShouldWorkAfterNetworkIssuesForNewRegistration() throws Exception { eventBus.start(); MailboxListener listener = newListener(); --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
