Fetch the repository succeeded.
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);
Sign in to post a comment
Repository Comments ( 0 )