- new TestKit(getSystem()) {
- {
- String memberId = "testHandleRegisterRoleChangeListenerWithNotificationSet";
- ActorRef listenerActor = getSystem().actorOf(MessageCollectorActor.props());
- ActorRef shardActor = getTestActor();
-
- TestActorRef<RoleChangeNotifier> notifierTestActorRef = TestActorRef.create(getSystem(),
- RoleChangeNotifier.getProps(memberId), memberId);
-
- notifierTestActorRef.tell(
- new RoleChanged(memberId, RaftState.Candidate.name(), RaftState.Leader.name()), shardActor);
+ String memberId = "testHandleRegisterRoleChangeListenerWithNotificationSet";
+ ActorRef listenerActor = getSystem().actorOf(MessageCollectorActor.props());
+ ActorRef shardActor = testKit.getTestActor();