+ clusterExtension.system().actorSelection(path).tell(new Identify(member.address()), TypedActor.context().self());
+ } else if (message instanceof ActorIdentity) {
+ LOG.debug("Received ActorIdentity message", message);
+ final String path = ((ActorIdentity) message).correlationId() + PATH + topologyId;
+ if (((ActorIdentity) message).getRef() == null) {
+ LOG.debug("ActorIdentity has null actor ref, retrying..", message);
+ final ActorRef self = TypedActor.context().self();
+ final ActorContext context = TypedActor.context();
+ system.scheduler().scheduleOnce(new FiniteDuration(5, TimeUnit.SECONDS), new Runnable() {
+ @Override
+ public void run() {
+ LOG.debug("Retrying identify message from master to node {} , full path {}", ((ActorIdentity) message).correlationId(), path);
+ context.system().actorSelection(path).tell(new Identify(((ActorIdentity) message).correlationId()), self);
+
+ }
+ }, system.dispatcher());
+ return;
+ }
+ LOG.debug("Actor at :{} is resolving topology actor for path {}, with a custom message", clusterExtension.selfAddress(), path);
+