The ShardManager wasn't receiving ReachableMember events from the akka
cluster because ClusterWrapperImpl wasn't subscribing for it.
Change-Id: I61f1be23bdffb1d9384fea6610c72d39d5a865aa
Signed-off-by: Tom Pantelis <tpanteli@brocade.com>
selfAddress = cluster.selfAddress();
}
selfAddress = cluster.selfAddress();
}
public void subscribeToMemberEvents(ActorRef actorRef){
Preconditions.checkNotNull(actorRef, "actorRef should not be null");
cluster.subscribe(actorRef, ClusterEvent.initialStateAsEvents(),
ClusterEvent.MemberEvent.class,
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() {
return currentMemberName;
}
public String getCurrentMemberName() {
return currentMemberName;
}
public Address getSelfAddress() {
return selfAddress;
}
public Address getSelfAddress() {
return selfAddress;
}