import static org.opendaylight.controller.md.cluster.datastore.model.TestModel.outerNode;
import static org.opendaylight.controller.md.cluster.datastore.model.TestModel.outerNodeEntry;
import static org.opendaylight.controller.md.cluster.datastore.model.TestModel.testNodeWithOuter;
+
import akka.actor.ActorRef;
import akka.dispatch.Dispatchers;
import akka.testkit.TestActorRef;
final ActorRef dclActor = actorFactory.createActor(DataChangeListener.props(listener),
"testChangeListenerWithNoInitialData-DataChangeListener");
final DataChangeListenerSupport support = new DataChangeListenerSupport(shard);
- support.onMessage(new RegisterChangeListener(TEST_PATH, dclActor, DataChangeScope.ONE, false),true,true);
+ support.onMessage(new RegisterChangeListener(TEST_PATH, dclActor, DataChangeScope.ONE, false),
+ true,true);
listener.expectNoMoreChanges("Unexpected initial change event");
}
final ActorRef dclActor = actorFactory.createActor(DataChangeListener.props(listener),
"testInitialChangeListenerEventWithContainerPath-DataChangeListener");
final DataChangeListenerSupport support = new DataChangeListenerSupport(shard);
- support.onMessage(new RegisterChangeListener(TEST_PATH, dclActor, DataChangeScope.ONE, false),true,true);
+ support.onMessage(new RegisterChangeListener(TEST_PATH, dclActor, DataChangeScope.ONE, false),
+ true,true);
listener.waitForChangeEvents(TEST_PATH);
}
final ActorRef dclActor = actorFactory.createActor(DataChangeListener.props(listener),
"testInitialChangeListenerEventWithNestedWildcardedListsPath-DataChangeListener");
final DataChangeListenerSupport support = new DataChangeListenerSupport(shard);
- support.onMessage(new RegisterChangeListener(OUTER_LIST_PATH.node(OUTER_LIST_QNAME).node(INNER_LIST_QNAME).node(INNER_LIST_QNAME), dclActor,
- DataChangeScope.ONE, false), true, true);
+ support.onMessage(new RegisterChangeListener(OUTER_LIST_PATH.node(OUTER_LIST_QNAME)
+ .node(INNER_LIST_QNAME).node(INNER_LIST_QNAME), dclActor, DataChangeScope.ONE, false),
+ true, true);
listener.waitForChangeEvents();
listener.verifyCreatedData(0, innerEntryPath(2, "four"));
}
};
-
}
}