X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-client%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fclient%2FTransmittingTransmitQueueTest.java;h=d6e9f5cec5065e52953f9ce0ea396cb29c8b2cdc;hb=refs%2Fchanges%2F10%2F78310%2F5;hp=8db4803c43c9bec7b43c94b6ee7ec100d163a41e;hpb=12fcdfe39aa26dcba7fd3bb4d4c68e3d02e65c51;p=controller.git diff --git a/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/TransmittingTransmitQueueTest.java b/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/TransmittingTransmitQueueTest.java index 8db4803c43..d6e9f5cec5 100644 --- a/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/TransmittingTransmitQueueTest.java +++ b/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/TransmittingTransmitQueueTest.java @@ -12,7 +12,7 @@ import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertThat; import static org.junit.Assert.assertTrue; -import static org.mockito.Matchers.any; +import static org.mockito.ArgumentMatchers.any; import static org.mockito.Mockito.doAnswer; import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.mock; @@ -64,7 +64,7 @@ public class TransmittingTransmitQueueTest extends AbstractTransmitQueueTest entries = queue.drain(); assertEquals(sentMessages, entries.size()); assertThat(entries, everyItem(entryWithRequest(request))); @@ -250,7 +250,7 @@ public class TransmittingTransmitQueueTest extends AbstractTransmitQueueTest { - invocation.getArgumentAt(0, SliceOptions.class).getOnFailureCallback().accept(new Exception("mock")); + invocation.getArgument(0).getOnFailureCallback().accept(new Exception("mock")); return Boolean.FALSE; }).when(mockMessageSlicer).slice(any()); @@ -288,7 +288,7 @@ public class TransmittingTransmitQueueTest extends AbstractTransmitQueueTest request2 = new TransactionPurgeRequest(TRANSACTION_IDENTIFIER, 1L, probe.ref()); queue.enqueueOrForward(new ConnectionEntry(request2, mockConsumer, now), now); verifyNoMoreInteractions(mockMessageSlicer); - probe.expectNoMsg(); + probe.expectNoMessage(); RequestEnvelope requestEnvelope = (RequestEnvelope) sliceOptions.getValue().getMessage(); queue.complete(new FailureEnvelope(request.toRequestFailure(mock(RequestException.class)),