From 126c0d5abe0d4a53de50d70657185e45820fbe59 Mon Sep 17 00:00:00 2001
From: "kezhu.wukz" <kezhu.wukz@alipay.com>
Date: Fri, 29 May 2020 19:15:00 +0800
Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=20https://github.com/sofastack/sof?=
 =?UTF-8?q?a-registry/issues/121?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sofa/registry/server/session/store/SessionInterests.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java b/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java
index 1ea664dc8..23ad94a24 100644
--- a/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java
+++ b/server/server/session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java
@@ -163,6 +163,8 @@ public boolean deleteByConnectId(String connectId) {
                     }
                 }
             }
+            //force remove connectId
+            invalidateConnectIndex(connectId);
             return true;
         } catch (Exception e) {
             LOGGER.error("Delete subscriber by connectId {} error!", connectId, e);