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 bt...@apache.org on 2019/01/15 09:58:19 UTC

[1/2] james-project git commit: MAILBOX-377 Fix asynchronous tests for In VM event delivery

Repository: james-project
Updated Branches:
  refs/heads/master c16d4e9b0 -> 8ff801e7f


MAILBOX-377 Fix asynchronous tests for In VM event delivery


Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/2e923247
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/2e923247
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/2e923247

Branch: refs/heads/master
Commit: 2e92324723baf5fe425d3a527ee0f20adb198720
Parents: c16d4e9
Author: Benoit Tellier <bt...@linagora.com>
Authored: Tue Jan 15 11:10:47 2019 +0700
Committer: Benoit Tellier <bt...@linagora.com>
Committed: Tue Jan 15 11:10:47 2019 +0700

----------------------------------------------------------------------
 .../james/mailbox/events/delivery/InVmEventDeliveryTest.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/james-project/blob/2e923247/mailbox/event/event-memory/src/test/java/org/apache/james/mailbox/events/delivery/InVmEventDeliveryTest.java
----------------------------------------------------------------------
diff --git a/mailbox/event/event-memory/src/test/java/org/apache/james/mailbox/events/delivery/InVmEventDeliveryTest.java b/mailbox/event/event-memory/src/test/java/org/apache/james/mailbox/events/delivery/InVmEventDeliveryTest.java
index 77194fb..9796328 100644
--- a/mailbox/event/event-memory/src/test/java/org/apache/james/mailbox/events/delivery/InVmEventDeliveryTest.java
+++ b/mailbox/event/event-memory/src/test/java/org/apache/james/mailbox/events/delivery/InVmEventDeliveryTest.java
@@ -44,6 +44,8 @@ import org.junit.jupiter.api.Test;
 
 import com.google.common.collect.ImmutableList;
 
+import reactor.core.publisher.Mono;
+
 class InVmEventDeliveryTest {
     private static final int DELIVERY_DELAY = (int) TimeUnit.MILLISECONDS.toMillis(100);
 
@@ -147,7 +149,9 @@ class InVmEventDeliveryTest {
             void deliverShouldDeliverEventToAsyncListenerWhenSyncGetException() {
                 doThrow(RuntimeException.class).when(syncEventCollector).event(event);
 
-                inVmEventDelivery.deliver(ImmutableList.of(asyncEventCollector, syncEventCollector), event).allListenerFuture().subscribe();
+                inVmEventDelivery.deliver(ImmutableList.of(asyncEventCollector, syncEventCollector), event).allListenerFuture()
+                    .onErrorResume(e -> Mono.empty())
+                    .block();
 
                 SoftAssertions.assertSoftly(softly -> {
                     softly.assertThat(syncEventCollector.getEvents()).isEmpty();


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


[2/2] james-project git commit: MAILBOX-377 Increase some too short timeouts in RabbitMQ event bus tests

Posted by bt...@apache.org.
MAILBOX-377 Increase some too short timeouts in RabbitMQ event bus tests

Slow computer may need more than 5 seconds to handle 10.000 deliveries...


Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/8ff801e7
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/8ff801e7
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/8ff801e7

Branch: refs/heads/master
Commit: 8ff801e7fc819a6bb20f8283d430931b53153ca0
Parents: 2e92324
Author: Benoit Tellier <bt...@linagora.com>
Authored: Tue Jan 15 14:13:20 2019 +0700
Committer: Benoit Tellier <bt...@linagora.com>
Committed: Tue Jan 15 14:13:20 2019 +0700

----------------------------------------------------------------------
 .../java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/james-project/blob/8ff801e7/mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events/RabbitMQEventBusTest.java
----------------------------------------------------------------------
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 8e5503a..8524e38 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
@@ -250,7 +250,7 @@ class RabbitMQEventBusTest implements GroupContract.SingleEventBusGroupContract,
                     .operation((threadNumber, step) -> eventBus.dispatch(EVENT, KEY_1))
                     .threadCount(10)
                     .operationCount(1000)
-                    .runSuccessfullyWithin(Duration.ofSeconds(5));
+                    .runSuccessfullyWithin(Duration.ofMinutes(1));
 
                 eventBus.stop();
                 int callsAfterStop = listener.numberOfEventCalls();


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