X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FMemberNode.java;h=fbfa91133f34f8a0bed1f2791d144c389fdd836a;hb=a6af137c30470b86d4bc624d4c48cb686495a182;hp=e6ea97124707cbd2cf85c605dba139bcf81628a4;hpb=b47ffc2df37ef67559274068d651c86aa666cbc3;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/MemberNode.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/MemberNode.java index e6ea971247..fbfa91133f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/MemberNode.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/MemberNode.java @@ -277,7 +277,7 @@ public class MemberNode { return this; } - public MemberNode build() { + public MemberNode build() throws Exception { Preconditions.checkNotNull(moduleShardsConfig, "moduleShardsConfig must be specified"); Preconditions.checkNotNull(akkaConfig, "akkaConfig must be specified"); Preconditions.checkNotNull(testName, "testName must be specified"); @@ -306,13 +306,13 @@ public class MemberNode { String memberName = new ClusterWrapperImpl(system).getCurrentMemberName().getName(); node.kit.getDatastoreContextBuilder().shardManagerPersistenceId("shard-manager-config-" + memberName); - node.configDataStore = node.kit.setupDistributedDataStore("config_" + testName, moduleShardsConfig, - true, schemaContext, waitForshardLeader); + node.configDataStore = node.kit.setupAbstractDataStore(DistributedDataStore.class, + "config_" + testName, moduleShardsConfig, true, schemaContext, waitForshardLeader); if (createOperDatastore) { node.kit.getDatastoreContextBuilder().shardManagerPersistenceId("shard-manager-oper-" + memberName); - node.operDataStore = node.kit.setupDistributedDataStore("oper_" + testName, moduleShardsConfig, - true, schemaContext, waitForshardLeader); + node.operDataStore = node.kit.setupAbstractDataStore(DistributedDataStore.class, + "oper_" + testName, moduleShardsConfig, true, schemaContext, waitForshardLeader); } members.add(node);