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 45d2f0619f0cb70d849f377c26131a82e2c236a2
Author: Tran Tien Duc <dt...@linagora.com>
AuthorDate: Mon Jun 17 11:05:05 2019 +0700
JAMES-2774 Remove useless comment & rename a test in RabbitMQEventBusTest
---
.../org/apache/james/mailbox/events/RabbitMQEventBusTest.java | 8 +++-----
1 file changed, 3 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 dac6986..49cfe24 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
@@ -186,11 +186,10 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
EventBusConcurrentTestContract.SingleEventBusConcurrentContract {
@Test
- void rabbitMQEventBusCannotHandleHugeDispatchingOperations() throws
Exception {
+ void rabbitMQEventBusShouldHandleBulksGracefully() throws Exception {
EventBusTestFixture.MailboxListenerCountingSuccessfulExecution
countingListener1 = newCountingListener();
-
eventBus().register(countingListener1, new
EventBusTestFixture.GroupA());
- int totalGlobalRegistrations = 1;
+ int totalGlobalRegistrations = 1; // GroupA
int threadCount = 10;
int operationCount = 10000;
@@ -200,9 +199,8 @@ class RabbitMQEventBusTest implements
GroupContract.SingleEventBusGroupContract,
.operation((threadNumber, operationNumber) ->
eventBus.dispatch(EVENT, NO_KEYS).block())
.threadCount(threadCount)
.operationCount(operationCount)
- .runSuccessfullyWithin(Duration.ofMinutes(10));
+ .runSuccessfullyWithin(Duration.ofMinutes(3));
- // there is a moment when RabbitMQ EventBus consumed amount of
messages, then it will stop to consume more
await()
.pollInterval(com.jayway.awaitility.Duration.FIVE_SECONDS)
.timeout(com.jayway.awaitility.Duration.TEN_MINUTES).until(()
->
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org
