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%2FOperationLimiterTest.java;h=d06a742c146d9b4e060096173a4deae0921e5fb8;hp=31a8776e5b86e09aba774c07951acbf2163add33;hb=7204c455a1636a7fc89bcd28fe9e9000eaa81b3b;hpb=4e3f49788c05730b29468deebc2aaa4ed0d94eef diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/OperationLimiterTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/OperationLimiterTest.java index 31a8776e5b..d06a742c14 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/OperationLimiterTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/OperationLimiterTest.java @@ -8,9 +8,9 @@ package org.opendaylight.controller.cluster.datastore; import static org.junit.Assert.assertEquals; + import org.junit.Test; -import org.opendaylight.controller.cluster.access.concepts.MemberName; -import org.opendaylight.controller.cluster.datastore.identifiers.TransactionIdentifier; +import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; import org.opendaylight.controller.cluster.datastore.messages.BatchedModificationsReply; import org.opendaylight.controller.cluster.datastore.messages.DataExistsReply; @@ -20,11 +20,13 @@ import org.opendaylight.controller.cluster.datastore.messages.DataExistsReply; * @author Thomas Pantelis */ public class OperationLimiterTest { + private final TransactionIdentifier transactionId = MockIdentifiers.transactionIdentifier( + OperationLimiterTest.class, "mock"); @Test public void testOnComplete() throws Exception { int permits = 10; - OperationLimiter limiter = new OperationLimiter(new TransactionIdentifier(MemberName.forName("foo"), 1), permits, 1); + OperationLimiter limiter = new OperationLimiter(transactionId, permits, 1); limiter.acquire(permits); int availablePermits = 0;