From f357bece629710f8d9916b070c0f4ce185f7ac75 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Tue, 16 Apr 2024 22:22:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=9B=9E=E8=B0=83=E8=AE=BE?=
 =?UTF-8?q?=E7=BD=AE=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java    | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

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<RedisRpcResponse> callback)  {
-        if (!callbacks.containsKey(key)) {
-            callbacks.put(key, callback);
-        }
-
+        // TODO 如果多个上级点播同一个通道会有问题
+        callbacks.put(key, callback);
     }
 
     public void removeCallback(long key)  {