X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FOpsBrokerTest.java;fp=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FRpcBrokerTest.java;h=793740c72a3bed2569fb3d9acccb99634ce61941;hp=7ea9191e7c7d4d07e868d94345197ea224b35978;hb=927bce5688e4b9d33d3e5e9b769d8a0dba5ccdd4;hpb=a2b838f96589b502578fa4e15cef2769f886a378;ds=sidebyside diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/RpcBrokerTest.java b/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/OpsBrokerTest.java similarity index 89% rename from opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/RpcBrokerTest.java rename to opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/OpsBrokerTest.java index 7ea9191e7c..793740c72a 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/RpcBrokerTest.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/OpsBrokerTest.java @@ -25,7 +25,7 @@ import org.opendaylight.mdsal.dom.spi.DefaultDOMRpcResult; import org.opendaylight.yangtools.util.concurrent.FluentFutures; import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; -public class RpcBrokerTest extends AbstractRpcTest { +public class OpsBrokerTest extends AbstractOpsTest { @Test public void testExecuteRpc() { @@ -33,14 +33,13 @@ public class RpcBrokerTest extends AbstractRpcTest { final DOMRpcResult rpcResult = new DefaultDOMRpcResult(invokeRpcResult); when(domRpcService1.invokeRpc(eq(TEST_RPC_TYPE), any())).thenReturn( FluentFutures.immediateFluentFuture(rpcResult)); + final ExecuteRpc executeRpc = ExecuteRpc.from(TEST_RPC_ID, null); - final ExecuteRpc executeMsg = ExecuteRpc.from(TEST_RPC_ID, null); - - rpcInvoker1.tell(executeMsg, rpcRegistry1Probe.getRef()); + rpcInvoker1.tell(executeRpc, rpcRegistry1Probe.getRef()); final RpcResponse rpcResponse = rpcRegistry1Probe.expectMsgClass(Duration.ofSeconds(5), RpcResponse.class); - assertEquals(rpcResult.getResult(), rpcResponse.getResultNormalizedNode()); + assertEquals(rpcResult.getResult(), rpcResponse.getOutput()); } @Test