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;
@Test
public void integrationTest() throws Exception {
+ ShardStrategyFactory.setConfiguration(new MockConfiguration());
DistributedDataStore distributedDataStore =
new DistributedDataStore(getSystem(), "config", new MockClusterWrapper(), new MockConfiguration());