Browse Source

优化回调设置方式

648540858 1 year ago
parent
commit
f357bece62

+ 2 - 4
src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java

@@ -193,10 +193,8 @@ public class RedisRpcConfig implements MessageListener {
     }
 
     private void setCallback(long key, CommonCallback<RedisRpcResponse> callback)  {
-        if (!callbacks.containsKey(key)) {
-            callbacks.put(key, callback);
-        }
-
+        // TODO 如果多个上级点播同一个通道会有问题
+        callbacks.put(key, callback);
     }
 
     public void removeCallback(long key)  {