stabilize AmqpConsumerActorTest

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
eclipse-ditto · Sep 9, 2021 · ffeb70b · ffeb70b
1 parent 81420c2
commit ffeb70b
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/...est/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActorTest.java b/...est/java/org/eclipse/ditto/connectivity/service/messaging/amqp/AmqpConsumerActorTest.java
@@ -460,16 +460,18 @@ public void closedMessageConsumerIsRecreatedAfterBackoffAndResourceStatusIsUpdat
                 final ModifyThing modifyThingViaNewConsumer = proxyActor.expectMsgClass(ModifyThing.class);
                 assertThat((CharSequence) modifyThingViaNewConsumer.getEntityId()).isEqualTo(
                         TestConstants.Things.THING_ID);
-
             }
 
             private void verifyResourceStatus(final ActorRef underTest, final String statusMessage,
                     final ConnectivityStatus expected) {
-                underTest.tell(RetrieveAddressStatus.getInstance(), getRef());
-                final var status = expectMsgClass(ResourceStatus.class);
-                assertThat((Object) status.getStatus()).isEqualTo(expected);
-                assertThat(status.getStatusDetails())
-                        .hasValueSatisfying(details -> assertThat(details).contains(statusMessage));
+                Awaitility.await("expecting resource status to be " + expected)
+                        .untilAsserted(() -> {
+                            underTest.tell(RetrieveAddressStatus.getInstance(), getRef());
+                            final var status = expectMsgClass(ResourceStatus.class);
+                            assertThat((Object) status.getStatus()).isEqualTo(expected);
+                            assertThat(status.getStatusDetails())
+                                    .hasValueSatisfying(details -> assertThat(details).contains(statusMessage));
+                        });
             }
 
             private MessageConsumer prepareMessageConsumer(final AtomicReference<MessageListener> ref)