Commit bd28ee49 by huangfusuper

执行机结果发送回调重试

parent abb490bc
...@@ -216,7 +216,7 @@ public class RpcReferenceBean { ...@@ -216,7 +216,7 @@ public class RpcReferenceBean {
client.asyncSend(finalAddress, rpcRequest); client.asyncSend(finalAddress, rpcRequest);
// future get // future get
logger.debug(">>>>>>>>>>>>数据:{},请求:{},的超时时间为:{}",rpcRequest,rpcRequest.getRequestId(),timeout); logger.info(">>>>>>>>>>>>数据:{},请求:{},的超时时间为:{}",rpcRequest,rpcRequest.getRequestId(),timeout);
RpcResponse rpcResponse = futureResponse.get(timeout, TimeUnit.MILLISECONDS); RpcResponse rpcResponse = futureResponse.get(timeout, TimeUnit.MILLISECONDS);
if (rpcResponse.getErrorMsg() != null) { if (rpcResponse.getErrorMsg() != null) {
throw new RpcException(rpcResponse.getErrorMsg()); throw new RpcException(rpcResponse.getErrorMsg());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment