diff --git a/net/src/main/java/com/zfoo/net/consumer/Consumer.java b/net/src/main/java/com/zfoo/net/consumer/Consumer.java index 740b0533..aacc7987 100644 --- a/net/src/main/java/com/zfoo/net/consumer/Consumer.java +++ b/net/src/main/java/com/zfoo/net/consumer/Consumer.java @@ -94,7 +94,7 @@ public class Consumer implements IConsumer { loadBalancer.afterLoadBalancer(session, packet, clientSignalAttachment); return syncAnswer; } catch (TimeoutException e) { - throw new NetTimeOutException(StringUtils.format("syncRequest timeout exception, ask:[{}], attachment:[{}]" + throw new NetTimeOutException(StringUtils.format("syncAsk timeout exception, ask:[{}], attachment:[{}]" , JsonUtils.object2String(packet), JsonUtils.object2String(clientSignalAttachment))); } finally { SignalBridge.removeSignalAttachment(clientSignalAttachment); diff --git a/net/src/main/java/com/zfoo/net/router/IRouter.java b/net/src/main/java/com/zfoo/net/router/IRouter.java index cd9afb3e..623fb319 100644 --- a/net/src/main/java/com/zfoo/net/router/IRouter.java +++ b/net/src/main/java/com/zfoo/net/router/IRouter.java @@ -39,7 +39,7 @@ public interface IRouter { void atReceiver(Session session, IPacket packet, @Nullable IAttachment attachment); /** - * attention:syncRequest和asyncRequest只能客户端调用 + * attention:syncAsk和asyncAsk只能客户端调用 * 同一个客户端可以同时发送多条同步或者异步消息。 * 服务器对每个请求消息也只能回复一条消息,不能在处理一条不同或者异步消息的时候回复多条消息。 * diff --git a/net/src/main/java/com/zfoo/net/router/Router.java b/net/src/main/java/com/zfoo/net/router/Router.java index 624775ff..baeea293 100644 --- a/net/src/main/java/com/zfoo/net/router/Router.java +++ b/net/src/main/java/com/zfoo/net/router/Router.java @@ -199,7 +199,7 @@ public class Router implements IRouter { return new SyncAnswer<>((T) responsePacket, clientSignalAttachment); } catch (TimeoutException e) { - throw new NetTimeOutException(StringUtils.format("syncRequest timeout exception, ask:[{}], attachment:[{}]" + throw new NetTimeOutException(StringUtils.format("syncAsk timeout exception, ask:[{}], attachment:[{}]" , JsonUtils.object2String(packet), JsonUtils.object2String(clientSignalAttachment))); } finally { SignalBridge.removeSignalAttachment(clientSignalAttachment);