.addListener(any(GenericFutureListener.class));
doReturn(mockChannelFuture).when(spySession).sendMessage(same(message));
- final var resultFuture = communicator.sendRequest(message, QName.create("", "mockRpc"));
+ final var resultFuture = communicator.sendRequest(message);
if (doLastTest) {
assertNotNull(resultFuture, "ListenableFuture is null");
}
final var message = new NetconfMessage(doc);
final var resultFuture =
- communicator.sendRequest(message, QName.create("", "mockRpc"));
+ communicator.sendRequest(message);
if (doLastTest) {
assertNotNull(resultFuture, "ListenableFuture is null");
}
setupSession();
final var message = new NetconfMessage(UntrustedXML.newDocumentBuilder().newDocument());
- final var rpc = QName.create("", "mockRpc");
final var futureListener = ArgumentCaptor.forClass(GenericFutureListener.class);
doReturn(mockChannelFuture).when(mockChannelFuture).addListener(futureListener.capture());
doReturn(mockChannelFuture).when(spySession).sendMessage(same(message));
- final var resultFuture = communicator.sendRequest(message, rpc);
+ final var resultFuture = communicator.sendRequest(message);
verify(spySession).sendMessage(same(message));
@Test
void testSendRequestWithNoSession() throws Exception {
final var message = new NetconfMessage(UntrustedXML.newDocumentBuilder().newDocument());
- final var rpc = QName.create("", "mockRpc");
- final var resultFuture = communicator.sendRequest(message, rpc);
+ final var resultFuture = communicator.sendRequest(message);
assertNotNull(resultFuture, "ListenableFuture is null");
setupSession();
final var message = new NetconfMessage(UntrustedXML.newDocumentBuilder().newDocument());
- final var rpc = QName.create("", "mockRpc");
final var futureListener = ArgumentCaptor.forClass(GenericFutureListener.class);
doReturn(mockChannelFuture).when(mockChannelFuture).addListener(futureListener.capture());
doReturn(mockChannelFuture).when(spySession).sendMessage(same(message));
- final var resultFuture = communicator.sendRequest(message, rpc);
+ final var resultFuture = communicator.sendRequest(message);
assertNotNull(resultFuture, "ListenableFuture is null");