fixed compile errors

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Jul 14, 2022 · 388453f · 388453f
1 parent 62ed425
commit 388453f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 9 deletions.
diff --git a/...rvice/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java b/...rvice/src/main/java/org/eclipse/ditto/connectivity/service/messaging/BaseClientActor.java
@@ -1734,7 +1734,7 @@ private Pair<ActorRef, ActorRef> startOutboundActors(final ProtocolAdapter proto
                 getContext().actorOf(outboundMappingProcessorActorProps, OutboundMappingProcessorActor.ACTOR_NAME);
 
         final Props outboundDispatchingProcessorActorProps = OutboundDispatchingActor.props(
-                commandForwarderActorSelection, settings, processorActor);
+                settings, processorActor);
         final ActorRef dispatchingActor =
                 getContext().actorOf(outboundDispatchingProcessorActorProps, OutboundDispatchingActor.ACTOR_NAME);
 

diff --git a/.../main/java/org/eclipse/ditto/connectivity/service/messaging/OutboundDispatchingActor.java b/.../main/java/org/eclipse/ditto/connectivity/service/messaging/OutboundDispatchingActor.java
@@ -59,22 +59,18 @@ final class OutboundDispatchingActor extends AbstractActor {
 
     private final OutboundMappingSettings settings;
     private final ActorRef outboundMappingProcessorActor;
-    private final ActorSelection commandForwarder;
 
     @SuppressWarnings("unused")
-    private OutboundDispatchingActor(final ActorSelection commandForwarder,
-            final OutboundMappingSettings settings,
+    private OutboundDispatchingActor(final OutboundMappingSettings settings,
             final ActorRef outboundMappingProcessorActor) {
 
-        this.commandForwarder = commandForwarder;
         this.settings = settings;
         this.outboundMappingProcessorActor = outboundMappingProcessorActor;
     }
 
-    static Props props(final ActorSelection commandForwarder, final OutboundMappingSettings settings,
-            final ActorRef outboundMappingProcessorActor) {
+    static Props props(final OutboundMappingSettings settings, final ActorRef outboundMappingProcessorActor) {
 
-        return Props.create(OutboundDispatchingActor.class, commandForwarder, settings, outboundMappingProcessorActor);
+        return Props.create(OutboundDispatchingActor.class, settings, outboundMappingProcessorActor);
     }
 
     @Override
@@ -161,7 +157,7 @@ private Signal<?> adjustSignalAndStartAckForwarder(final Signal<?> signal, final
             // start ackregator for source declared acks
             return AcknowledgementForwarderActor.startAcknowledgementForwarder(getContext(),
                     self(),
-                    commandForwarder,
+                    settings.getProxyActor(),
                     entityId,
                     signal,
                     settings.getAcknowledgementConfig(),