couler

RPCServer<RequestPojo, ResponsePojo> server = new RPCServer<RequestPojo, ResponsePojo>(9008, 3000,new MyProcessor(),protostuffSerializer);
try {
    server.open();
} catch (IOException e) {
    e.printStackTrace();
}

SyncRPCClient<RequestPojo, ResponsePojo> client = new SyncRPCClient<RequestPojo, ResponsePojo>("localhost",9008, 5,protostuffSerializer);
client.open();
RequestPojo request = new RequestPojo();
ResponsePojo response = client.call(request,10000);