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%2Fdatabroker%2Factors%2Fdds%2FLocalProxyTransactionTest.java;h=7815a262084de004fbff00f1117c6614f28ce16c;hp=6f66b3e933134b3bbcd048b970631b04a0b4d24e;hb=808a02471eef0f975c13fc948f933fac34ada387;hpb=85c23944a273c338098997700b14f3a802025bb5 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/LocalProxyTransactionTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/LocalProxyTransactionTest.java index 6f66b3e933..7815a26208 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/LocalProxyTransactionTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/LocalProxyTransactionTest.java @@ -66,7 +66,7 @@ public abstract class LocalProxyTransactionTest transaction.handleForwardedRemoteRequest(request, callback); final ArgumentCaptor captor = ArgumentCaptor.forClass(Response.class); verify(callback).accept(captor.capture()); - final Response value = captor.getValue(); + final Response value = captor.getValue(); Assert.assertTrue(value instanceof ReadTransactionSuccess); final ReadTransactionSuccess success = (ReadTransactionSuccess) value; Assert.assertTrue(success.getData().isPresent()); @@ -82,7 +82,7 @@ public abstract class LocalProxyTransactionTest transaction.handleForwardedRemoteRequest(request, callback); final ArgumentCaptor captor = ArgumentCaptor.forClass(Response.class); verify(callback).accept(captor.capture()); - final Response value = captor.getValue(); + final Response value = captor.getValue(); Assert.assertTrue(value instanceof ExistsTransactionSuccess); final ExistsTransactionSuccess success = (ExistsTransactionSuccess) value; Assert.assertTrue(success.getExists()); @@ -135,7 +135,7 @@ public abstract class LocalProxyTransactionTest testForwardToLocal(request, TransactionPurgeRequest.class); } - protected T testForwardToLocal(final TransactionRequest toForward, + protected > T testForwardToLocal(final TransactionRequest toForward, final Class expectedMessageClass) { final Consumer> callback = createCallbackMock(); final TransactionTester transactionTester = createLocalProxy(); @@ -151,7 +151,7 @@ public abstract class LocalProxyTransactionTest * @param invocation invocation * @return void - always null */ - protected Answer applyToCursorAnswer(final InvocationOnMock invocation) { + protected Answer applyToCursorAnswer(final InvocationOnMock invocation) { final DataTreeModificationCursor cursor = invocation.getArgumentAt(0, DataTreeModificationCursor.class); cursor.write(PATH_1.getLastPathArgument(), DATA_1);