eclipse-ditto#985 fix KafkaClientActorTest

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
bosch-io · Mar 23, 2021 · 1a5c8c2 · 1a5c8c2
1 parent 4d1b7f8
commit 1a5c8c2
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/...ging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java b/...ging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/BaseClientActor.java
@@ -935,7 +935,6 @@ private FSM.State<BaseClientState, BaseClientData> testConnection(final TestConn
                 .setConnectionStatusDetails("Testing connection since " + Instant.now()));
     }
 
-
     private State<BaseClientState, BaseClientData> testingConnectionFailed(final ConnectionFailure event,
             final BaseClientData data) {
         logger.info("{} failed: <{}>", stateName(), event.getFailure());

diff --git a/...st/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActorTest.java b/...st/java/org/eclipse/ditto/services/connectivity/messaging/kafka/KafkaClientActorTest.java
@@ -195,6 +195,7 @@ public void testTestConnectionFails() {
             final ActorRef kafkaClientActor = actorSystem.actorOf(props);
 
             kafkaClientActor.tell(TestConnection.of(connection, DittoHeaders.empty()), getRef());
+            expectMsgClass(Duration.ofSeconds(10), KafkaPublisherActor.GracefulStop.class);
             expectMsgClass(Duration.ofSeconds(10), Status.Failure.class);
         }};
     }