From 34fdd28345ec093291c67b5700c08fa10b02c2d9 Mon Sep 17 00:00:00 2001 From: BeyondWUXF <46481385+BeyondWUXF@users.noreply.github.com> Date: Mon, 24 Jan 2022 18:40:23 +0800 Subject: [PATCH] Update servant.go --- tars/servant.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tars/servant.go b/tars/servant.go index 99abd244..749f2b4a 100755 --- a/tars/servant.go +++ b/tars/servant.go @@ -192,7 +192,7 @@ func (s *ServantProxy) doInvoke(ctx context.Context, msg *Message, timeout time. if adp == nil { return errors.New("no adapter Proxy selected:" + msg.Req.SServantName) } - if s.queueLen > ObjQueueMax { + if s.queueLen > adp.comm.Client.ObjQueueMax { return errors.New("invoke queue is full:" + msg.Req.SServantName) } ep := adp.GetPoint()