@Test public void testNotDeserializableRpc() throws Exception { RpcServer server = autoClose(new RpcServer(emptyConfig)); Rpc[] rpcs = createRpcConnection(server); Rpc client = rpcs[1]; try { client.call(new NotDeserializable(42)).get(10, TimeUnit.SECONDS); } catch (ExecutionException ee) { assertTrue(ee.getCause() instanceof RpcException); assertTrue(ee.getCause().getMessage().indexOf("KryoException") >= 0); } }
public Future<Void> call(Object msg) { return call(msg, Void.class); }
Rpc implements Closeable { public Future<Void> call(Object msg) { return call(msg, Void.class); } }
Rpc implements Closeable { public Future<Void> call(Object msg) { return call(msg, Void.class); } private  Rpc(RpcConfiguration config, Channel channel, EventExecutorGroup egroup); }
Rpc implements Closeable { public Future<Void> call(Object msg) { return call(msg, Void.class); } private  Rpc(RpcConfiguration config, Channel channel, EventExecutorGroup egroup); static Promise<Rpc> createClient(
      Map<String, String> config,
      final NioEventLoopGroup eloop,
      String host,
      int port,
      final String clientId,
      final String secret,
      final RpcDispatcher dispatcher); void addListener(Listener l); Future<Void> call(Object msg); Future<T> call(Object msg, Class<T> retType); Promise<T> createPromise(); @Override void close(); }
Rpc implements Closeable { public Future<Void> call(Object msg) { return call(msg, Void.class); } private  Rpc(RpcConfiguration config, Channel channel, EventExecutorGroup egroup); static Promise<Rpc> createClient(
      Map<String, String> config,
      final NioEventLoopGroup eloop,
      String host,
      int port,
      final String clientId,
      final String secret,
      final RpcDispatcher dispatcher); void addListener(Listener l); Future<Void> call(Object msg); Future<T> call(Object msg, Class<T> retType); Promise<T> createPromise(); @Override void close();  }