Authored by jack

Revert "增加异常捕获范围"

This reverts commit 0037030f.
@@ -62,12 +62,10 @@ public class TwemproxyTask extends Task { @@ -62,12 +62,10 @@ public class TwemproxyTask extends Task {
62 62
63 twemproxyInfo = new TwemproxyInfo(this.getIp(), this.getPort(), info); 63 twemproxyInfo = new TwemproxyInfo(this.getIp(), this.getPort(), info);
64 64
65 - } catch (Exception e) { 65 + } catch (IOException e) {
66 66
67 this.getAlarmMsgService().sendSms("Twemproxy", "Failed to query Twemproxy " + this.getUrl() + " monitor info.", this.getSnsMobileConfig().getBaseMobile()); 67 this.getAlarmMsgService().sendSms("Twemproxy", "Failed to query Twemproxy " + this.getUrl() + " monitor info.", this.getSnsMobileConfig().getBaseMobile());
68 68
69 - DEBUG.error("Failed to query twemproxy {} info ... error {}", this.getUrl(), e);  
70 -  
71 return; 69 return;
72 } 70 }
73 71
@@ -140,7 +138,7 @@ public class TwemproxyTask extends Task { @@ -140,7 +138,7 @@ public class TwemproxyTask extends Task {
140 138
141 for (Map.Entry<String, Long> entry : twemproxyInfo.getRequestMap().entrySet()) { 139 for (Map.Entry<String, Long> entry : twemproxyInfo.getRequestMap().entrySet()) {
142 140
143 - taskService.submit(new RedisTask(entry.getKey(), entry.getValue(), this.getUrl(), this.getAlarmMsgService(), this.getSnsMobileConfig())); 141 + taskService.submit(new RedisTask(entry.getKey(), entry.getValue(),this.getUrl(), this.getAlarmMsgService(), this.getSnsMobileConfig()));
144 } 142 }
145 143
146 taskService.shutdown(); 144 taskService.shutdown();