...
|
...
|
@@ -62,10 +62,12 @@ public class TwemproxyTask extends Task { |
|
|
|
|
|
twemproxyInfo = new TwemproxyInfo(this.getIp(), this.getPort(), info);
|
|
|
|
|
|
} catch (IOException e) {
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
this.getAlarmMsgService().sendSms("Twemproxy", "Failed to query Twemproxy " + this.getUrl() + " monitor info.", this.getSnsMobileConfig().getBaseMobile());
|
|
|
|
|
|
DEBUG.error("Failed to query twemproxy {} monitor info...error {} ", this.getUrl(), e);
|
|
|
|
|
|
return;
|
|
|
}
|
|
|
|
...
|
...
|
@@ -138,7 +140,7 @@ public class TwemproxyTask extends Task { |
|
|
|
|
|
for (Map.Entry<String, Long> entry : twemproxyInfo.getRequestMap().entrySet()) {
|
|
|
|
|
|
taskService.submit(new RedisTask(entry.getKey(), entry.getValue(),this.getUrl(), this.getAlarmMsgService(), this.getSnsMobileConfig()));
|
|
|
taskService.submit(new RedisTask(entry.getKey(), entry.getValue(), this.getUrl(), this.getAlarmMsgService(), this.getSnsMobileConfig()));
|
|
|
}
|
|
|
|
|
|
taskService.shutdown();
|
...
|
...
|
|