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;
import org.opendaylight.controller.cluster.datastore.Shard;
import org.opendaylight.controller.cluster.datastore.ShardTest;
import org.opendaylight.controller.cluster.datastore.ShardTestKit;
-import org.opendaylight.controller.cluster.datastore.TransactionProxy;
+import org.opendaylight.controller.cluster.datastore.TransactionType;
import org.opendaylight.controller.cluster.datastore.identifiers.ShardIdentifier;
import org.opendaylight.controller.cluster.datastore.messages.AbortTransactionReply;
import org.opendaylight.controller.cluster.datastore.messages.CanCommitTransactionReply;
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.<String,String>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> shard = TestActorRef.create(getSystem(), shardProps,
"testTransactionCommit");
String transactionID = "txn-1";
shard.tell(ShardTransactionMessages.CreateTransaction.newBuilder()
.setTransactionId(transactionID)
- .setTransactionType(TransactionProxy.TransactionType.WRITE_ONLY.ordinal())
+ .setTransactionType(TransactionType.WRITE_ONLY.ordinal())
.setTransactionChainId("").build(), getRef());
final FiniteDuration duration = duration("5 seconds");
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.<String,String>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> shard = TestActorRef.create(getSystem(), shardProps,
"testTransactionAbort");
String transactionID = "txn-1";
shard.tell(ShardTransactionMessages.CreateTransaction.newBuilder()
.setTransactionId(transactionID)
- .setTransactionType(TransactionProxy.TransactionType.WRITE_ONLY.ordinal())
+ .setTransactionType(TransactionType.WRITE_ONLY.ordinal())
.setTransactionChainId("").build(), getRef());
final FiniteDuration duration = duration("5 seconds");