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;
+import org.opendaylight.controller.cluster.access.concepts.MemberName;
public class ClusterWrapperImpl implements ClusterWrapper {
private final Cluster cluster;
- private final String currentMemberName;
+ private final MemberName currentMemberName;
+ private final Address selfAddress;
+
+ public ClusterWrapperImpl(ActorSystem actorSystem) {
+ Preconditions.checkNotNull(actorSystem, "actorSystem should not be null");
- public ClusterWrapperImpl(ActorSystem actorSystem){
cluster = Cluster.get(actorSystem);
- currentMemberName = (String) cluster.getSelfRoles().toArray()[0];
+ Preconditions.checkState(cluster.getSelfRoles().size() > 0,
+ "No akka roles were specified.\n"
+ + "One way to specify the member name is to pass a property on the command line like so\n"
+ + " -Dakka.cluster.roles.0=member-3\n"
+ + "member-3 here would be the name of the member");
+
+ currentMemberName = MemberName.forName(cluster.getSelfRoles().iterator().next());
+ selfAddress = cluster.selfAddress();
}
- public void subscribeToMemberEvents(ActorRef actorRef){
+ @Override
+ public void subscribeToMemberEvents(ActorRef actorRef) {
+ Preconditions.checkNotNull(actorRef, "actorRef should not be null");
+
cluster.subscribe(actorRef, ClusterEvent.initialStateAsEvents(),
ClusterEvent.MemberEvent.class,
- ClusterEvent.UnreachableMember.class);
+ ClusterEvent.UnreachableMember.class,
+ ClusterEvent.ReachableMember.class);
}
- public String getCurrentMemberName() {
+ @Override
+ public MemberName getCurrentMemberName() {
return currentMemberName;
}
+
+ @Override
+ public Address getSelfAddress() {
+ return selfAddress;
+ }
}