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%2Fcompat%2FShardTransactionHeliumBackwardsCompatibilityTest.java;h=42b6d0d961b01ff4219e4a858ca1b908af038cfc;hp=cdbab1c6d1c7b9cdd70bddf92efc733ee64d7f93;hb=196fbf9b716ea26740195fd397c1b2550f656638;hpb=5be2bbf5512e82010faf62de8138bacc8ffb9c6e diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/ShardTransactionHeliumBackwardsCompatibilityTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/ShardTransactionHeliumBackwardsCompatibilityTest.java index cdbab1c6d1..42b6d0d961 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/ShardTransactionHeliumBackwardsCompatibilityTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/compat/ShardTransactionHeliumBackwardsCompatibilityTest.java @@ -13,7 +13,6 @@ import akka.actor.PoisonPill; import akka.actor.Props; import akka.dispatch.Dispatchers; import akka.testkit.TestActorRef; -import java.util.Collections; import org.junit.Assert; import org.junit.Test; import org.opendaylight.controller.cluster.datastore.AbstractActorTest; @@ -57,11 +56,10 @@ public class ShardTransactionHeliumBackwardsCompatibilityTest extends AbstractAc public void testTransactionCommit() throws Exception { new ShardTestKit(getSystem()) {{ SchemaContext schemaContext = TestModel.createTestContext(); - Props shardProps = Shard.props(ShardIdentifier.builder().memberName("member-1"). - shardName("inventory").type("config").build(), - Collections.emptyMap(), - DatastoreContext.newBuilder().shardHeartbeatIntervalInMillis(100).build(), - schemaContext).withDispatcher(Dispatchers.DefaultDispatcherId()); + Props shardProps = Shard.builder().id(ShardIdentifier.builder().memberName("member-1"). + shardName("inventory").type("config").build()).datastoreContext(DatastoreContext.newBuilder(). + shardHeartbeatIntervalInMillis(100).build()).schemaContext(schemaContext).props(). + withDispatcher(Dispatchers.DefaultDispatcherId()); final TestActorRef shard = TestActorRef.create(getSystem(), shardProps, "testTransactionCommit"); @@ -131,11 +129,10 @@ public class ShardTransactionHeliumBackwardsCompatibilityTest extends AbstractAc public void testTransactionAbort() throws Exception { new ShardTestKit(getSystem()) {{ SchemaContext schemaContext = TestModel.createTestContext(); - Props shardProps = Shard.props(ShardIdentifier.builder().memberName("member-1"). - shardName("inventory").type("config").build(), - Collections.emptyMap(), - DatastoreContext.newBuilder().shardHeartbeatIntervalInMillis(100).build(), - schemaContext).withDispatcher(Dispatchers.DefaultDispatcherId()); + Props shardProps = Shard.builder().id(ShardIdentifier.builder().memberName("member-1"). + shardName("inventory").type("config").build()).datastoreContext(DatastoreContext.newBuilder(). + shardHeartbeatIntervalInMillis(100).build()).schemaContext(schemaContext).props(). + withDispatcher(Dispatchers.DefaultDispatcherId()); final TestActorRef shard = TestActorRef.create(getSystem(), shardProps, "testTransactionAbort");