throw new UnsupportedOperationException("onDataChanged");
}
}
throw new UnsupportedOperationException("onDataChanged");
}
}
@@ -58,7+60,7 @@ public class DataChangeListenerRegistrationProxyTest extends AbstractActorTest{
//Check if it was received by the remote actor
ActorContext
//Check if it was received by the remote actor
ActorContext
- testContext = new ActorContext(getSystem(), getSystem().actorOf(Props.create(DoNothingActor.class)));
+ testContext = new ActorContext(getSystem(), getSystem().actorOf(Props.create(DoNothingActor.class)),new MockClusterWrapper(), new MockConfiguration());
Object messages = testContext
.executeLocalOperation(actorRef, "messages",
ActorContext.ASK_DURATION);
Object messages = testContext
.executeLocalOperation(actorRef, "messages",
ActorContext.ASK_DURATION);
@@ -71,6+73,6 @@ public class DataChangeListenerRegistrationProxyTest extends AbstractActorTest{