X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatabroker%2FClientBackedReadTransactionTest.java;h=08316b83911c5bb763962009bfafe869d9083112;hb=HEAD;hp=35d9d112a4b1a8932d7eae18e31db6b5513a4258;hpb=a85197fcfedf2894b98439ea0ad66b3f5a0eb00b;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ClientBackedReadTransactionTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ClientBackedReadTransactionTest.java index 35d9d112a4..08316b8391 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ClientBackedReadTransactionTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/ClientBackedReadTransactionTest.java @@ -8,27 +8,27 @@ package org.opendaylight.controller.cluster.databroker; import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; import static org.mockito.Mockito.doReturn; import static org.opendaylight.yangtools.util.concurrent.FluentFutures.immediateFluentFuture; import static org.opendaylight.yangtools.util.concurrent.FluentFutures.immediateTrueFluentFuture; -import com.google.common.util.concurrent.ListenableFuture; import java.util.Optional; import org.junit.Before; import org.junit.Test; +import org.junit.runner.RunWith; import org.mockito.Mock; -import org.mockito.MockitoAnnotations; +import org.mockito.junit.MockitoJUnitRunner; import org.opendaylight.controller.cluster.access.client.ClientActorContext; import org.opendaylight.controller.cluster.databroker.actors.dds.ClientSnapshot; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; -import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; +import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; +@RunWith(MockitoJUnitRunner.StrictStubs.class) public class ClientBackedReadTransactionTest extends ClientBackedTransactionTest { private ClientBackedReadTransaction object; @Mock - private NormalizedNode data; + private ContainerNode data; @Mock private ClientActorContext clientContext; @Mock @@ -41,28 +41,21 @@ public class ClientBackedReadTransactionTest extends ClientBackedTransactionTest @Before public void setUp() { - MockitoAnnotations.initMocks(this); - - doReturn(CLIENT_ID).when(clientContext).getIdentifier(); doReturn(TRANSACTION_ID).when(delegate).getIdentifier(); - doReturn(immediateTrueFluentFuture()).when(delegate).exists(YangInstanceIdentifier.EMPTY); - doReturn(immediateFluentFuture(Optional.of(data))).when(delegate).read(YangInstanceIdentifier.EMPTY); + doReturn(immediateTrueFluentFuture()).when(delegate).exists(YangInstanceIdentifier.of()); + doReturn(immediateFluentFuture(Optional.of(data))).when(delegate).read(YangInstanceIdentifier.of()); object = new ClientBackedReadTransaction(delegate, null, null); } @Test public void testRead() throws Exception { - final ListenableFuture>> result = object().read(YangInstanceIdentifier.EMPTY); - final Optional> resultData = result.get(); - assertTrue(resultData.isPresent()); - assertEquals(data, resultData.get()); + assertEquals(Optional.of(data), object().read(YangInstanceIdentifier.of()).get()); } @Test public void testExists() throws Exception { - final ListenableFuture result = object().exists(YangInstanceIdentifier.EMPTY); - assertEquals(Boolean.TRUE, result.get()); + assertEquals(Boolean.TRUE, object().exists(YangInstanceIdentifier.of()).get()); } }