Merge pull request #323 from BeyondWUXF/master

配置文件client objQueueMax不生效
TarsCloud · Jan 24, 2022 · b9033cb · b9033cb
2 parents ebe3b8d + 2f8d5b4
commit b9033cb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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()