X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDistributedDataStoreIntegrationTest.java;h=6a25328a4d2559c2ea654284bc48e17191e367e7;hp=f400e74231f83b7f72881656fe891404a0b7b24d;hb=d83a4d45f6ddbd66842a43dcb230f2c81af91696;hpb=44c747db358bf0d49434d5f818121286b5928d4a diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreIntegrationTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreIntegrationTest.java index f400e74231..6a25328a4d 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreIntegrationTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DistributedDataStoreIntegrationTest.java @@ -3,6 +3,9 @@ package org.opendaylight.controller.cluster.datastore; import com.google.common.base.Optional; import com.google.common.util.concurrent.ListenableFuture; import org.junit.Test; +import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategyFactory; +import org.opendaylight.controller.cluster.datastore.utils.MockClusterWrapper; +import org.opendaylight.controller.cluster.datastore.utils.MockConfiguration; import org.opendaylight.controller.md.cluster.datastore.model.TestModel; import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction; import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort; @@ -16,8 +19,9 @@ public class DistributedDataStoreIntegrationTest extends AbstractActorTest { @Test public void integrationTest() throws Exception { + ShardStrategyFactory.setConfiguration(new MockConfiguration()); DistributedDataStore distributedDataStore = - new DistributedDataStore(getSystem(), "config"); + new DistributedDataStore(getSystem(), "config", new MockClusterWrapper(), new MockConfiguration()); distributedDataStore.onGlobalContextUpdated(TestModel.createTestContext());