临时提交

src/main/java/com/genersoft/iot/vmp/conf/redis/RedisRpcConfig.java

@@ -6,6 +6,7 @@ import com.genersoft.iot.vmp.conf.UserSetting;
 import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcMessage;
 import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcRequest;
 import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcResponse;
+import com.genersoft.iot.vmp.media.zlm.ZlmHttpHookSubscribe;
 import com.genersoft.iot.vmp.service.redisMsg.control.RedisRpcController;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -45,6 +46,9 @@ public class RedisRpcConfig implements MessageListener {
     @Autowired
     private RedisTemplate<Object, Object> redisTemplate;
 
+    @Autowired
+    private ZlmHttpHookSubscribe hookSubscribe;
+
     private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>();
 
     @Qualifier("taskExecutor")
@@ -216,5 +220,6 @@ public class RedisRpcConfig implements MessageListener {
     public void execute(){
         System.out.println("callbacks的长度: " + callbacks.size());
         System.out.println("队列的长度: " + topicSubscribers.size());
+        System.out.println("HOOK监听的长度: " + hookSubscribe.size());
     }
 }

src/main/java/com/genersoft/iot/vmp/media/zlm/ZlmHttpHookSubscribe.java

@@ -158,4 +158,8 @@ public class ZlmHttpHookSubscribe {
             }
         }
     }
+
+    public int size(){
+        return allSubscribes.size();
+    }
 }