Skip to content
Permalink
Browse files

reused actor system from local var

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
  • Loading branch information
thjaeckle committed Jun 7, 2019
1 parent b3ca549 commit 7fbae3decca7b4afa8e5a17c649991f512b28d79
@@ -30,6 +30,7 @@
import akka.NotUsed;
import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Cancellable;
import akka.actor.Props;
import akka.event.DiagnosticLoggingAdapter;
@@ -68,11 +69,12 @@ private ReconnectActor(final ActorRef connectionShardRegion,
this.connectionShardRegion = connectionShardRegion;
this.currentPersistenceIdsSourceSupplier = currentPersistenceIdsSourceSupplier;

final ActorSystem system = getContext().getSystem();

reconnectConfig = DittoConnectivityConfig.of(
DefaultScopedConfig.dittoScoped(getContext().getSystem().settings().config())
DefaultScopedConfig.dittoScoped(system.settings().config())
).getReconnectConfig();

materializer = ActorMaterializer.create(getContext().getSystem());
materializer = ActorMaterializer.create(system);
}

/**

0 comments on commit 7fbae3d

Please sign in to comment.
You can’t perform that action at this time.