From cd5ca05e739ad0d31aa640617b111dd4a7c6b80c Mon Sep 17 00:00:00 2001
From: "scott.wang" <sxllwx@github.com>
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 c0d5fe291..aa2082848 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)
-- 
GitLab