修复系统监控推送问题

zhou-hao · zhou-hao · commit f44a84cbf4bc · 2016-10-27T18:26:40.000+08:00
diff --git a/hsweb-web-websocket/src/main/java/org/hsweb/web/socket/cmd/support/SystemMonitorProcessor.java b/hsweb-web-websocket/src/main/java/org/hsweb/web/socket/cmd/support/SystemMonitorProcessor.java
@@ -45,7 +45,6 @@ public void exec(CMD cmd) throws Exception {
             Publish publish = new Publish();
             publish.setUserId(userId);
             publish.setCallback((String) cmd.getParams().get("callback"));
-            cpuPublish.put(userId, publish);
             return publish;
         };
 
@@ -55,6 +54,7 @@ public void exec(CMD cmd) throws Exception {
                 if (publish == null)
                     publish = supplier.get();
                 publish.addSession(cmd.getSession());
+                cpuPublish.put(userId, publish);
                 if (!cpuMonitorIsStarted) {
                     startPublishCpu();
                     cpuMonitorIsStarted = true;
@@ -66,6 +66,7 @@ public void exec(CMD cmd) throws Exception {
                 if (publish == null)
                     publish = supplier.get();
                 publish.addSession(cmd.getSession());
+                memPublish.put(userId, publish);
                 if (!memMonitorIsStarted) {
                     startPublishMem();
                     memMonitorIsStarted = true;
