avoid unnecessary watch

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
eclipse-ditto · Aug 10, 2022 · 8fa2c2b · 8fa2c2b
1 parent edd3d1d
commit 8fa2c2b
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/...pse/ditto/connectivity/service/messaging/mqtt/hivemq/consuming/MqttConsumerActorTest.java b/...pse/ditto/connectivity/service/messaging/mqtt/hivemq/consuming/MqttConsumerActorTest.java
@@ -426,15 +426,15 @@ public void reconnectConsumerClientForRedeliveryIfInboundMessageIsRejected() {
         final var onCompleteMessage = new Object();
         final var fakeMqttClientActor = ACTOR_SYSTEM_RESOURCE.newTestKit();
 
-        fakeMqttClientActor.watch(fakeMqttClientActor.childActorOf(
+        fakeMqttClientActor.childActorOf(
                 MqttConsumerActor.propsProcessing(connection,
                         Sink.actorRef(inboundMappingSinkElementReceiver.getRef(), onCompleteMessage),
                         connectionSource,
                         connectivityStatusResolver,
                         TestConstants.CONNECTIVITY_CONFIG,
                         Source.single(GenericMqttPublish.ofMqtt5Publish(mqtt5Publish))),
                 testName.getMethodName()
-        ));
+        );
 
         final var externalMessageWithSender =
                 inboundMappingSinkElementReceiver.expectMsgClass(ExternalMessageWithSender.class);
@@ -469,15 +469,15 @@ public void doNotRedeliverRejectedMessageIfShouldDeliverButReconnectForRedeliver
         final var onCompleteMessage = new Object();
         final var fakeMqttClientActor = ACTOR_SYSTEM_RESOURCE.newTestKit();
 
-        fakeMqttClientActor.watch(fakeMqttClientActor.childActorOf(
+        fakeMqttClientActor.childActorOf(
                 MqttConsumerActor.propsProcessing(connection,
                         Sink.actorRef(inboundMappingSinkElementReceiver.getRef(), onCompleteMessage),
                         connectionSource,
                         connectivityStatusResolver,
                         connectivityConfig,
                         Source.single(GenericMqttPublish.ofMqtt5Publish(mqtt5Publish))),
                 testName.getMethodName()
-        ));
+        );
 
         final var externalMessageWithSender =
                 inboundMappingSinkElementReceiver.expectMsgClass(ExternalMessageWithSender.class);
@@ -506,15 +506,15 @@ public void acknowledgeRejectedIncomingMessageIfShouldNotRedeliver() {
         final var onCompleteMessage = new Object();
         final var fakeMqttClientActor = ACTOR_SYSTEM_RESOURCE.newTestKit();
 
-        fakeMqttClientActor.watch(fakeMqttClientActor.childActorOf(
+        fakeMqttClientActor.childActorOf(
                 MqttConsumerActor.propsProcessing(connection,
                         Sink.actorRef(inboundMappingSinkElementReceiver.getRef(), onCompleteMessage),
                         connectionSource,
                         connectivityStatusResolver,
                         TestConstants.CONNECTIVITY_CONFIG,
                         Source.single(GenericMqttPublish.ofMqtt5Publish(mqtt5Publish))),
                 testName.getMethodName()
-        ));
+        );
 
         final var externalMessageWithSender =
                 inboundMappingSinkElementReceiver.expectMsgClass(ExternalMessageWithSender.class);
@@ -543,15 +543,15 @@ public void rejectIncomingMessageDueToDittoRuntimeExceptionInsteadOfAcknowledgem
         final var onCompleteMessage = new Object();
         final var fakeMqttClientActor = ACTOR_SYSTEM_RESOURCE.newTestKit();
 
-        fakeMqttClientActor.watch(fakeMqttClientActor.childActorOf(
+        fakeMqttClientActor.childActorOf(
                 MqttConsumerActor.propsProcessing(connection,
                         Sink.actorRef(inboundMappingSinkElementReceiver.getRef(), onCompleteMessage),
                         connectionSource,
                         connectivityStatusResolver,
                         TestConstants.CONNECTIVITY_CONFIG,
                         Source.single(GenericMqttPublish.ofMqtt5Publish(mqtt5Publish))),
                 testName.getMethodName()
-        ));
+        );
 
         final var externalMessageWithSender =
                 inboundMappingSinkElementReceiver.expectMsgClass(ExternalMessageWithSender.class);