Showing
3 changed files
with
15 additions
and
3 deletions
@@ -34,6 +34,8 @@ public class ClusterViewJob implements Callable { | @@ -34,6 +34,8 @@ public class ClusterViewJob implements Callable { | ||
34 | } | 34 | } |
35 | 35 | ||
36 | public void doTask() { | 36 | public void doTask() { |
37 | + DEBUG.info("Start to execute cluster view job in moid {}", this.moId); | ||
38 | + | ||
37 | MObjectInfo moInfo = InterVar.moMaps.get(moId); | 39 | MObjectInfo moInfo = InterVar.moMaps.get(moId); |
38 | 40 | ||
39 | String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.NODES_URL; | 41 | String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.NODES_URL; |
@@ -71,6 +73,8 @@ public class ClusterViewJob implements Callable { | @@ -71,6 +73,8 @@ public class ClusterViewJob implements Callable { | ||
71 | 73 | ||
72 | InterVar.clusterViewMaps.put(moId, oneView); | 74 | InterVar.clusterViewMaps.put(moId, oneView); |
73 | } | 75 | } |
76 | + | ||
77 | + DEBUG.info("End to execute cluster view job in moid {}", this.moId); | ||
74 | } | 78 | } |
75 | 79 | ||
76 | @Override | 80 | @Override |
@@ -41,6 +41,9 @@ public class OverViewJob implements Callable { | @@ -41,6 +41,9 @@ public class OverViewJob implements Callable { | ||
41 | } | 41 | } |
42 | 42 | ||
43 | public void doTask() { | 43 | public void doTask() { |
44 | + | ||
45 | + DEBUG.info("Start to execute over view job in moid {}", this.moId); | ||
46 | + | ||
44 | MObjectInfo moInfo = InterVar.moMaps.get(moId); | 47 | MObjectInfo moInfo = InterVar.moMaps.get(moId); |
45 | 48 | ||
46 | String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.OVERVIEW_URL; | 49 | String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.OVERVIEW_URL; |
@@ -100,6 +103,8 @@ public class OverViewJob implements Callable { | @@ -100,6 +103,8 @@ public class OverViewJob implements Callable { | ||
100 | 103 | ||
101 | InterVar.overViewMaps.put(moId, overViewModel); | 104 | InterVar.overViewMaps.put(moId, overViewModel); |
102 | } | 105 | } |
106 | + | ||
107 | + DEBUG.info("End to execute over view job in moid {}", this.moId); | ||
103 | } | 108 | } |
104 | 109 | ||
105 | @Override | 110 | @Override |
@@ -58,6 +58,8 @@ public class QueueViewJob implements Callable { | @@ -58,6 +58,8 @@ public class QueueViewJob implements Callable { | ||
58 | } | 58 | } |
59 | 59 | ||
60 | public void doTask() { | 60 | public void doTask() { |
61 | + DEBUG.info("Start to execute queue view job in moid {}", this.moId); | ||
62 | + | ||
61 | MObjectInfo moInfo = InterVar.moMaps.get(moId); | 63 | MObjectInfo moInfo = InterVar.moMaps.get(moId); |
62 | 64 | ||
63 | String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.QUEUE_URL; | 65 | String url = MessageFormat.format(InterVar.URLFORMAT, moInfo.getMoHostIp(), InterVar.port) + InterVar.QUEUE_URL; |
@@ -106,6 +108,8 @@ public class QueueViewJob implements Callable { | @@ -106,6 +108,8 @@ public class QueueViewJob implements Callable { | ||
106 | 108 | ||
107 | InterVar.queueViewMaps.put(moId, oneView); | 109 | InterVar.queueViewMaps.put(moId, oneView); |
108 | } | 110 | } |
111 | + | ||
112 | + DEBUG.info("End to execute queue view job in moid {}", this.moId); | ||
109 | } | 113 | } |
110 | 114 | ||
111 | 115 | ||
@@ -153,9 +157,8 @@ public class QueueViewJob implements Callable { | @@ -153,9 +157,8 @@ public class QueueViewJob implements Callable { | ||
153 | } | 157 | } |
154 | 158 | ||
155 | //初始化 | 159 | //初始化 |
156 | - private void initQueueAlert(String moId, QueueInfo queueInfo) | ||
157 | - { | ||
158 | - RabbitAlertInfo alertInfo=new RabbitAlertInfo(); | 160 | + private void initQueueAlert(String moId, QueueInfo queueInfo) { |
161 | + RabbitAlertInfo alertInfo = new RabbitAlertInfo(); | ||
159 | 162 | ||
160 | alertInfo.setAlertHigh(200); | 163 | alertInfo.setAlertHigh(200); |
161 | 164 |
-
Please register or login to post a comment