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 rc...@apache.org on 2020/03/04 08:03:48 UTC
[james-project] 02/09: JAMES-3083 disable rabbitMQ event bus
needing a rabbitmq restart
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 001d30b64e3ca928b10a0527462b9808ff2679fd
Author: Rémi KOWALSKI <rk...@linagora.com>
AuthorDate: Mon Mar 2 15:20:44 2020 +0100
JAMES-3083 disable rabbitMQ event bus needing a rabbitmq restart
---
.../james/mailbox/events/RabbitMQEventBusTest.java | 18 ++++++++++++------
1 file changed, 12 insertions(+), 6 deletions(-)
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 bac1407..5436749 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
@@ -362,7 +362,8 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
}
@Test
- void dispatchShouldWorkAfterRestartForOldRegistration() {
+ @Disabled("To fix in JAMES-3082 make message persistent in event bus")
+ void dispatchShouldWorkAfterRestartForOldRegistration() throws Exception {
eventBus.start();
MailboxListener listener = newListener();
eventBus.register(listener, GROUP_A);
@@ -374,7 +375,8 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
}
@Test
- void dispatchShouldWorkAfterRestartForNewRegistration() {
+ @Disabled("To fix in JAMES-3082 make message persistent in event bus")
+ void dispatchShouldWorkAfterRestartForNewRegistration() throws Exception {
eventBus.start();
MailboxListener listener = newListener();
@@ -389,7 +391,8 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
}
@Test
- void redeliverShouldWorkAfterRestartForOldRegistration() {
+ @Disabled("To fix in JAMES-3082 make message persistent in event bus")
+ void redeliverShouldWorkAfterRestartForOldRegistration() throws Exception {
eventBus.start();
MailboxListener listener = newListener();
eventBus.register(listener, GROUP_A);
@@ -401,7 +404,8 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
}
@Test
- void redeliverShouldWorkAfterRestartForNewRegistration() {
+ @Disabled("To fix in JAMES-3082 make message persistent in event bus")
+ void redeliverShouldWorkAfterRestartForNewRegistration() throws Exception {
eventBus.start();
MailboxListener listener = newListener();
@@ -414,7 +418,8 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
}
@Test
- void dispatchShouldWorkAfterRestartForOldKeyRegistration() {
+ @Disabled("To fix in JAMES-3082 make message persistent in event bus")
+ void dispatchShouldWorkAfterRestartForOldKeyRegistration() throws Exception {
eventBus.start();
MailboxListener listener = newListener();
eventBus.register(listener, KEY_1);
@@ -426,7 +431,8 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
}
@Test
- void dispatchShouldWorkAfterRestartForNewKeyRegistration() {
+ @Disabled("To fix in JAMES-3082 make message persistent in event bus")
+ void dispatchShouldWorkAfterRestartForNewKeyRegistration() 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