- public void testInvokeRpc() {
- RpcResult<CompositeNode> expResult = mock( RpcResult.class );
- Future<RpcResult<CompositeNode>> future = Futures.immediateFuture( expResult );
- when( mockConsumerSession.rpc( qname, dataNode ) ).thenReturn( future );
-
- RpcResult<CompositeNode> actualResult = brokerFacade.invokeRpc( qname, dataNode );
-
- assertSame( "invokeRpc", expResult, actualResult );
- }
+ public void testInvokeRpc() throws Exception {
+ RpcResult<CompositeNode> expResult = mock(RpcResult.class);
+ Future<RpcResult<CompositeNode>> future = Futures.immediateFuture(expResult);
+ when(mockConsumerSession.rpc(qname, dataNode)).thenReturn(future);