临时提交

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

@@ -202,4 +202,9 @@ public class RedisRpcConfig implements MessageListener {
     public void removeCallback(long key)  {
         callbacks.remove(key);
     }
+
+
+    public int getCallbackCount(){
+        return callbacks.size();
+    }
 }

src/main/java/com/genersoft/iot/vmp/vmanager/log/LogController.java

@@ -2,6 +2,7 @@ package com.genersoft.iot.vmp.vmanager.log;
 
 import com.genersoft.iot.vmp.conf.UserSetting;
 import com.genersoft.iot.vmp.conf.exception.ControllerException;
+import com.genersoft.iot.vmp.conf.redis.RedisRpcConfig;
 import com.genersoft.iot.vmp.conf.security.JwtUtils;
 import com.genersoft.iot.vmp.service.ILogService;
 import com.genersoft.iot.vmp.storager.dao.dto.LogDto;
@@ -92,4 +93,14 @@ public class LogController {
         logService.clear();
     }
 
+    @Autowired
+    private RedisRpcConfig redisRpcConfig;
+
+    @GetMapping("/test/count")
+    public Object count() {
+        return redisRpcConfig.getCallbackCount();
+    }
+
+
+
 }

src/main/resources/application.yml

@@ -2,4 +2,4 @@ spring:
   application:
     name: wvp
   profiles:
-    active: local
+    active: local2