zhulu 9 сар өмнө
parent
commit
1781d70052

+ 1 - 1
soc-common/soc-common-core/src/main/java/com/xunmei/common/core/constant/RedisConstant.java

@@ -14,7 +14,7 @@ public class RedisConstant {
     public static final String TOPIC_KEY_WEBSOCKET = "websocket_topic_key";
 
     // host模块主机发送失败消息重试队列订阅者数量后缀
-    public static final String TOPIC_SUBSCRIBERS_NUMS = TOPIC_KEY_WEBSOCKET + "_Subscribers_";
+    public static final String TOPIC_SUBSCRIBERS_NUMS = TOPIC_KEY_WEBSOCKET + "_Subscribers:";
 
     // redis 订阅者因链接不在当前实例而发送失败后 增加发送失败数量
     public static final String ADD_SUBSCRIBERS_AND_FAIL_NUMS = "add_SubscribersAndFailNums";