stabilized AmqpClientActorTest.testSetMessageListenerOnConsumerFails

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Nov 4, 2021 · f5b5a28 · f5b5a28
1 parent 9b8b02c
commit f5b5a28
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActorTest.java b/.../test/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpClientActorTest.java
@@ -472,7 +472,7 @@ public void testSetMessageListenerOnConsumerFails() throws JMSException {
             amqpClientActor.tell(OpenConnection.of(CONNECTION_ID, DittoHeaders.empty()), getRef());
             expectMsgClass(Status.Failure.class);
 
-            final AtomicInteger count = new AtomicInteger(20);
+            final AtomicInteger count = new AtomicInteger(40);
             Awaitility.await()
                     .pollInterval(Duration.ofMillis(100))
                     .atMost(Duration.ofSeconds(5)).until(() -> {