fix： #121 (#122)

Co-authored-by: kezhu.wukz <kezhu.wukz@alipay.com>
sofastack · Aug 23, 2020 · a2a50d5 · a2a50d5
1 parent bea8df7
commit a2a50d5
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);