System.out.print("Send direct message from unreachable peer");
final String request = "Hello ";
final String response = "World!";
Peer receiver = peers[42];
receiver.objectDataReply(new ObjectDataReply() {
public Object reply(PeerAddress sender, Object request) throws Exception {
Assert.assertEquals(request.toString(), request);
return response;
}
});