fixed unit test in ConnectivityProxyActorTest

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · May 20, 2022 · da1289f · da1289f
1 parent c6b4a7b
commit da1289f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...est/java/org/eclipse/ditto/connectivity/service/messaging/ConnectivityProxyActorTest.java b/...est/java/org/eclipse/ditto/connectivity/service/messaging/ConnectivityProxyActorTest.java
@@ -21,6 +21,8 @@
 
 import org.eclipse.ditto.base.model.headers.DittoHeaders;
 import org.eclipse.ditto.base.model.signals.Signal;
+import org.eclipse.ditto.internal.utils.cluster.DistPubSubAccess;
+import org.eclipse.ditto.things.api.ThingsMessagingConstants;
 import org.eclipse.ditto.things.model.Thing;
 import org.eclipse.ditto.things.model.ThingId;
 import org.eclipse.ditto.things.model.signals.commands.query.RetrieveThingResponse;
@@ -81,8 +83,8 @@ public void testRetrieveThings() {
             // WHEN: RetrieveThings is sent to proxy actor
             proxy.tell(retrieveThings, getRef());
 
-            // THEN: command is forwarded to concierge
-            expectMsg(retrieveThings);
+            // THEN: command is forwarded to things aggregator actor
+            expectMsg(DistPubSubAccess.send(ThingsMessagingConstants.THINGS_AGGREGATOR_ACTOR_PATH, retrieveThings));
 
             // WHEN: concierge responds with SourceRef of things
             final SourceRef<RetrieveThingResponse> retrieveThingResponseSourceRef =