import akka.actor.ActorRef;
import akka.actor.ActorSystem;
+import akka.actor.Address;
import akka.cluster.Cluster;
import akka.cluster.ClusterEvent;
import com.google.common.base.Preconditions;
public class ClusterWrapperImpl implements ClusterWrapper {
private final Cluster cluster;
private final String currentMemberName;
- private final String selfAddress;
+ private final Address selfAddress;
public ClusterWrapperImpl(ActorSystem actorSystem){
Preconditions.checkNotNull(actorSystem, "actorSystem should not be null");
"member-3 here would be the name of the member"
);
- currentMemberName = (String) cluster.getSelfRoles().toArray()[0];
- selfAddress = cluster.selfAddress().toString();
-
+ currentMemberName = cluster.getSelfRoles().iterator().next();
+ selfAddress = cluster.selfAddress();
}
public void subscribeToMemberEvents(ActorRef actorRef){
return currentMemberName;
}
- public String getSelfAddress() {
+ public Address getSelfAddress() {
return selfAddress;
}
}