You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/01/25 03:55:24 UTC
[08/10] james-project git commit: MAILBOX-374 Also test EventBus
behaviour when confronted with RabbitMQ restarts
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 <bt...@linagora.com>
Authored: Thu Jan 24 16:27:36 2019 +0700
Committer: Benoit Tellier <bt...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org