From fa4babdcb44ee93ee4dbeb731cc6ce4a99afede1 Mon Sep 17 00:00:00 2001 From: jaysunxiao Date: Wed, 3 Nov 2021 21:53:26 +0800 Subject: [PATCH] =?UTF-8?q?doc[net]:=20=E6=9B=B4=E6=96=B0=E6=96=87?= =?UTF-8?q?=E6=A1=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- net/src/main/java/com/zfoo/net/consumer/Consumer.java | 2 +- net/src/main/java/com/zfoo/net/router/IRouter.java | 2 +- net/src/main/java/com/zfoo/net/router/Router.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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);