[james-project] 02/07: [refactoring use untilAsserted in place of until in RabbitMQEventBustTest

[rcordier]

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 7cb3bcf350b445c0079ce4441954eed9cfe4d313
Author: Rémi KOWALSKI <rkowal...@linagora.com>
AuthorDate: Wed Dec 4 16:58:37 2019 +0100

    [refactoring use untilAsserted in place of until in RabbitMQEventBustTest
---
 .../org/apache/james/mailbox/events/RabbitMQEventBusTest.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 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 1f0ffc8..ed97aec 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
@@ -195,8 +195,8 @@ class RabbitMQEventBusTest implements 
GroupContract.SingleEventBusGroupContract,
 
             await()
                 .pollInterval(org.awaitility.Duration.FIVE_SECONDS)
-                .timeout(org.awaitility.Duration.TEN_MINUTES).until(() ->
-                    countingListener1.numberOfEventCalls() == 
(totalGlobalRegistrations * totalDispatchOperations));
+                .timeout(org.awaitility.Duration.TEN_MINUTES).untilAsserted(() 
->
+                    
assertThat(countingListener1.numberOfEventCalls()).isEqualTo((totalGlobalRegistrations
 * totalDispatchOperations)));
         }
 
         @Override
@@ -238,15 +238,15 @@ class RabbitMQEventBusTest implements 
GroupContract.SingleEventBusGroupContract,
 
             eventBus.dispatch(EVENT, NO_KEYS).block();
             WAIT_CONDITION
-                .until(() -> eventBusListener.numberOfEventCalls() == 1);
+                .untilAsserted(() -> 
assertThat(eventBusListener.numberOfEventCalls()).isEqualTo(1));
             eventBus.stop();
 
             WAIT_CONDITION
-                .until(() -> eventBus2Listener.numberOfEventCalls() == 1);
+                .untilAsserted(() -> 
assertThat(eventBus2Listener.numberOfEventCalls()).isEqualTo(1));
             eventBus2.stop();
 
             WAIT_CONDITION
-                .until(() -> eventBus3Listener.numberOfEventCalls() == 1);
+                .untilAsserted(() -> 
assertThat(eventBus3Listener.numberOfEventCalls()).isEqualTo(1));
         }
     }
 


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