[james-project] 24/28: JAMES-2659 dispatch result should always be waited for success

[btellier]

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 2be4ed2270df8c5b278084e2549a2f127ae4013a
Author: Matthieu Baechler <matth...@apache.org>
AuthorDate: Fri Jun 21 14:31:05 2019 +0200

    JAMES-2659 dispatch result should always be waited for success
---
 .../java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 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 d160031..50df7d4 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
@@ -297,7 +297,7 @@ class RabbitMQEventBusTest implements 
GroupContract.SingleEventBusGroupContract,
 
         @Test
         void dispatchShouldPublishSerializedEventToRabbitMQWhenNotBlocking() {
-            eventBus.dispatch(EVENT, NO_KEYS);
+            eventBus.dispatch(EVENT, NO_KEYS).block();
 
             assertThat(dequeueEvent()).isEqualTo(EVENT);
         }
@@ -566,7 +566,7 @@ class RabbitMQEventBusTest implements 
GroupContract.SingleEventBusGroupContract,
                 eventBus.register(listener, GROUP_A);
 
                 try (Closeable closeable = ConcurrentTestRunner.builder()
-                    .operation((threadNumber, step) -> 
eventBus.dispatch(EVENT, KEY_1))
+                    .operation((threadNumber, step) -> 
eventBus.dispatch(EVENT, KEY_1).block())
                     .threadCount(THREAD_COUNT)
                     .operationCount(OPERATION_COUNT)
                     .run()) {
@@ -659,7 +659,7 @@ class RabbitMQEventBusTest implements 
GroupContract.SingleEventBusGroupContract,
                 eventBus2.register(listener, GROUP_A);
 
                 try (Closeable closeable = ConcurrentTestRunner.builder()
-                    .operation((threadNumber, step) -> 
eventBus.dispatch(EVENT, KEY_1))
+                    .operation((threadNumber, step) -> 
eventBus.dispatch(EVENT, KEY_1).block())
                     .threadCount(THREAD_COUNT)
                     .operationCount(OPERATION_COUNT)
                     .run()) {


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org