stabilize AmqpClientActorTest

eclipse-ditto · Oct 30, 2019 · be452f7 · be452f7
1 parent b3db20b
commit be452f7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java b/...test/java/org/eclipse/ditto/services/connectivity/messaging/amqp/AmqpClientActorTest.java
@@ -773,6 +773,7 @@ public void testConsumerRecreationFailureWhenConnected() throws JMSException {
 
                 // THEN: connection gets restarted
                 verify(mockConnection).createSession(anyInt());
+                latch.countDown();
                 final ArgumentCaptor<MessageListener> captor = ArgumentCaptor.forClass(MessageListener.class);
                 verify(mockConsumer2, timeout(1000).atLeastOnce()).setMessageListener(captor.capture());
                 final MessageListener messageListener = captor.getValue();