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()