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 2019/12/05 02:27:04 UTC
[james-project] 02/07: [refactoring use untilAsserted in place of
until in RabbitMQEventBustTest
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 <rk...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org