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.testkit.TestActorRef;
import org.junit.After;
import org.junit.Test;
import org.opendaylight.controller.cluster.datastore.messages.RegisterDataTreeChangeListener;
import org.opendaylight.controller.cluster.datastore.utils.MockDataTreeChangeListener;
-import org.opendaylight.controller.cluster.raft.TestActorFactory;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
import org.opendaylight.yangtools.yang.data.impl.schema.ImmutableNodes;
* @author Thomas Pantelis
*/
public class DataTreeChangeListenerSupportTest extends AbstractShardTest {
- private final TestActorFactory actorFactory = new TestActorFactory(getSystem());
-
private Shard shard;
private DataTreeChangeListenerSupport support;
listener2.verifyNoNotifiedData(innerEntryPath(2, "three"), innerEntryPath(2, "four"));
}
- private MockDataTreeChangeListener registerChangeListener(YangInstanceIdentifier path,
- int expectedEvents, boolean isLeader) {
+ private MockDataTreeChangeListener registerChangeListener(final YangInstanceIdentifier path,
+ final int expectedEvents, final boolean isLeader) {
MockDataTreeChangeListener listener = new MockDataTreeChangeListener(expectedEvents);
ActorRef dclActor = actorFactory.createActor(DataTreeChangeListenerActor.props(listener));
support.onMessage(new RegisterDataTreeChangeListener(path, dclActor, false), isLeader, true);
private Shard createShard() {
TestActorRef<Shard> actor = actorFactory.createTestActor(newShardProps());
+ ShardTestKit.waitUntilLeader(actor);
return actor.underlyingActor();
}
}