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() {
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