Skip to content

Commit

Permalink
remove putting searchactor ref to pubSubMediator because searchActor …
Browse files Browse the repository at this point in the history
…registeres itself via pubSub;

Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
  • Loading branch information
Stefan Maute committed Sep 26, 2022
1 parent c9ab376 commit 06770ae
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@
import org.eclipse.ditto.base.service.RootChildActorStarter;
import org.eclipse.ditto.base.service.actors.DittoRootActor;
import org.eclipse.ditto.internal.utils.akka.streaming.TimestampPersistence;
import org.eclipse.ditto.internal.utils.cluster.DistPubSubAccess;
import org.eclipse.ditto.internal.utils.config.ScopedConfig;
import org.eclipse.ditto.internal.utils.persistence.mongo.DittoMongoClient;
import org.eclipse.ditto.internal.utils.persistence.mongo.streaming.MongoTimestampPersistence;
Expand Down Expand Up @@ -64,9 +63,9 @@ private SearchRootActor(final SearchConfig searchConfig, final ActorRef pubSubMe
RootChildActorStarter.get(actorSystem, ScopedConfig.dittoExtension(actorSystem.settings().config()))
.execute(getContext());

final var thingsSearchPersistence = getThingsSearchPersistence(searchConfig, mongoDbClient);
final var thingsSearchPersistence =
getThingsSearchPersistence(searchConfig, mongoDbClient);
final ActorRef searchActor = initializeSearchActor(searchConfig, thingsSearchPersistence, pubSubMediator);
pubSubMediator.tell(DistPubSubAccess.put(searchActor), getSelf());

final TimestampPersistence backgroundSyncPersistence =
MongoTimestampPersistence.initializedInstance(BACKGROUND_SYNC_COLLECTION_NAME, mongoDbClient,
Expand Down

0 comments on commit 06770ae

Please sign in to comment.