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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
