fix： sofastack#121 (sofastack#122)

Co-authored-by: kezhu.wukz <kezhu.wukz@alipay.com>
nocvalight · Aug 23, 2020 · 6def0d5 · 6def0d5
1 parent a6e5e3e
commit 6def0d5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java b/...session/src/main/java/com/alipay/sofa/registry/server/session/store/SessionInterests.java
@@ -167,6 +167,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);