@Test(expected = IllegalStateException.class) public void cantSendWithoutAttaching() { prepareSequentialExecutorService(); asyncRpcSender.send(() -> MessageType.REQUEST); }
@Override public void send(Message message) { this.executorService.submit(() -> sendMessage(message)); }
AsyncRpcSender implements RpcSender { @Override public void send(Message message) { this.executorService.submit(() -> sendMessage(message)); } }
AsyncRpcSender implements RpcSender { @Override public void send(Message message) { this.executorService.submit(() -> sendMessage(message)); } AsyncRpcSender(ExecutorService executorService, ObjectMapper msgPacker); }
AsyncRpcSender implements RpcSender { @Override public void send(Message message) { this.executorService.submit(() -> sendMessage(message)); } AsyncRpcSender(ExecutorService executorService, ObjectMapper msgPacker); @Override void send(Message message); @Override void attach(OutputStream outputStream); @Override void stop(); }
AsyncRpcSender implements RpcSender { @Override public void send(Message message) { this.executorService.submit(() -> sendMessage(message)); } AsyncRpcSender(ExecutorService executorService, ObjectMapper msgPacker); @Override void send(Message message); @Override void attach(OutputStream outputStream); @Override void stop();  }