From 9e718c273e699d2b0a816f94a99cbc7b41d60431 Mon Sep 17 00:00:00 2001 From: "scott.wang" Date: Wed, 14 Aug 2019 11:06:53 +0800 Subject: [PATCH] [ISSUE #163] clean heartbeat from PendingResponse --- protocol/dubbo/listener.go | 1 + 1 file changed, 1 insertion(+) diff --git a/protocol/dubbo/listener.go b/protocol/dubbo/listener.go index c0d5fe2916..aa20828482 100644 --- a/protocol/dubbo/listener.go +++ b/protocol/dubbo/listener.go @@ -91,6 +91,7 @@ func (h *RpcClientHandler) OnMessage(session getty.Session, pkg interface{}) { if p.Err != nil { logger.Errorf("rpc heartbeat response{error: %#v}", p.Err) } + h.conn.pool.rpcClient.removePendingResponse(SequenceType(p.Header.ID)) return } logger.Debugf("get rpc response{header: %#v, body: %#v}", p.Header, p.Body)