diff --git a/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java b/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java index 545fdc11..a57c3128 100644 --- a/src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java +++ b/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 callback) { - if (!callbacks.containsKey(key)) { - callbacks.put(key, callback); - } - + // TODO 如果多个上级点播同一个通道会有问题 + callbacks.put(key, callback); } public void removeCallback(long key) {