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%2FShardTransactionFailureTest.java;h=fa5e8f33b1a582413950be0acf11ed3c08136351;hp=2eec393304d4d52e968900eba6d4229733145feb;hb=refs%2Fchanges%2F91%2F84091%2F17;hpb=c9ca1a93d44cfb7681079b7ca3c56ea89ac3ef1b diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTransactionFailureTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTransactionFailureTest.java index 2eec393304..fa5e8f33b1 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTransactionFailureTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/ShardTransactionFailureTest.java @@ -75,12 +75,12 @@ public class ShardTransactionFailureTest extends AbstractActorTest { "testNegativeReadWithReadOnlyTransactionClosed"); Future future = akka.pattern.Patterns.ask(subject, - new ReadData(YangInstanceIdentifier.EMPTY, DataStoreVersions.CURRENT_VERSION), 3000); + new ReadData(YangInstanceIdentifier.empty(), DataStoreVersions.CURRENT_VERSION), 3000); Await.result(future, FiniteDuration.create(3, TimeUnit.SECONDS)); subject.underlyingActor().getDOMStoreTransaction().abortFromTransactionActor(); - future = akka.pattern.Patterns.ask(subject, new ReadData(YangInstanceIdentifier.EMPTY, + future = akka.pattern.Patterns.ask(subject, new ReadData(YangInstanceIdentifier.empty(), DataStoreVersions.CURRENT_VERSION), 3000); Await.result(future, FiniteDuration.create(3, TimeUnit.SECONDS)); } @@ -97,12 +97,12 @@ public class ShardTransactionFailureTest extends AbstractActorTest { "testNegativeReadWithReadWriteTransactionClosed"); Future future = akka.pattern.Patterns.ask(subject, - new ReadData(YangInstanceIdentifier.EMPTY, DataStoreVersions.CURRENT_VERSION), 3000); + new ReadData(YangInstanceIdentifier.empty(), DataStoreVersions.CURRENT_VERSION), 3000); Await.result(future, FiniteDuration.create(3, TimeUnit.SECONDS)); subject.underlyingActor().getDOMStoreTransaction().abortFromTransactionActor(); - future = akka.pattern.Patterns.ask(subject, new ReadData(YangInstanceIdentifier.EMPTY, + future = akka.pattern.Patterns.ask(subject, new ReadData(YangInstanceIdentifier.empty(), DataStoreVersions.CURRENT_VERSION), 3000); Await.result(future, FiniteDuration.create(3, TimeUnit.SECONDS)); } @@ -118,13 +118,13 @@ public class ShardTransactionFailureTest extends AbstractActorTest { "testNegativeExistsWithReadWriteTransactionClosed"); Future future = akka.pattern.Patterns.ask(subject, - new DataExists(YangInstanceIdentifier.EMPTY, DataStoreVersions.CURRENT_VERSION), 3000); + new DataExists(YangInstanceIdentifier.empty(), DataStoreVersions.CURRENT_VERSION), 3000); Await.result(future, FiniteDuration.create(3, TimeUnit.SECONDS)); subject.underlyingActor().getDOMStoreTransaction().abortFromTransactionActor(); future = akka.pattern.Patterns.ask(subject, - new DataExists(YangInstanceIdentifier.EMPTY, DataStoreVersions.CURRENT_VERSION), 3000); + new DataExists(YangInstanceIdentifier.empty(), DataStoreVersions.CURRENT_VERSION), 3000); Await.result(future, FiniteDuration.create(3, TimeUnit.SECONDS)); } }