JgroupsMessageSender { public <T> T sendToAddressSync(Address address, Serializable content) throws Exception { return this.dispatcher.sendMessage(new Message(address, Util.objectToByteBuffer(content)), SYNC_OPTIONS); } JgroupsMessageSender(MessageDispatcher dispatcher); RspList<T> sendToClusterSync(Serializable content); void sendToClusterAsync(Serializable content, Set<Address> addressesToSkip, FutureListener<RspList<T>> listener); void sendToClusterAsync(Serializable content, FutureListener<RspList<T>> listener); void sendToAddressAsync(Address address, Serializable content); T sendToAddressSync(Address address, Serializable content); boolean isEmptyCluster();  }
@Test public void testSendToAddressSync() throws Exception { String id = UUID.randomUUID().toString(); jgroupsMessageSender.sendToAddressSync(address, id); new Verifications() {{ Message msg; RequestOptions options; dispatcher.sendMessage(msg = withCapture(), options = withCapture()); assertThat(msg.getObject()).isEqualTo(id); assertThat(msg.getDest()).isEqualTo(address); assertThat(options.getMode()).isEqualTo(ResponseMode.GET_ALL); }}; }