fix BackgroundSyncActorTest;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
eclipse-ditto · Sep 22, 2022 · 95d1f2f · 95d1f2f
1 parent 352b0ba
commit 95d1f2f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...st/java/org/eclipse/ditto/thingsearch/service/updater/actors/BackgroundSyncActorTest.java b/...st/java/org/eclipse/ditto/thingsearch/service/updater/actors/BackgroundSyncActorTest.java
@@ -344,8 +344,8 @@ private void expectSyncActorToStartStreaming(final TestKit pubSub, final Duratio
 
     private void expectSyncActorToStartStreaming(final TestKit pubSub, final Duration withinTimeout,
             final Consumer<SudoStreamSnapshots> msgAssertions) {
-        final DistributedPubSubMediator.Send startStream =
-                pubSub.expectMsgClass(withinTimeout, DistributedPubSubMediator.Send.class);
+        final DistributedPubSubMediator.Publish startStream =
+                pubSub.expectMsgClass(withinTimeout, DistributedPubSubMediator.Publish.class);
         assertThat(startStream.msg()).isInstanceOf(SudoStreamSnapshots.class);
         msgAssertions.accept(((SudoStreamSnapshots) startStream.msg()));
     }