public class DataChangeListenerRegistrationProxyTest extends AbstractActorTest{
+ private ActorRef dataChangeListenerActor = getSystem().actorOf(Props.create(DoNothingActor.class));
+
private static class MockDataChangeListener implements
AsyncDataChangeListener<InstanceIdentifier, NormalizedNode<?, ?>> {
DataChangeListenerRegistrationProxy proxy =
new DataChangeListenerRegistrationProxy(
getSystem().actorSelection(actorRef.path()),
- listener);
+ listener, dataChangeListenerActor);
Assert.assertEquals(listener, proxy.getInstance());
DataChangeListenerRegistrationProxy proxy =
new DataChangeListenerRegistrationProxy(
getSystem().actorSelection(actorRef.path()),
- new MockDataChangeListener());
+ new MockDataChangeListener(), dataChangeListenerActor);
proxy.close();