增加异常捕获范围

jack · jack
Commit 0037030f8b528ea00d6d67b4b704540e32aaaa2a 1 parent e8054e12
Showing 1 changed file with 4 additions and 2 deletions
monitor-service-middleware/src/main/java/com/monitor/middleware/redis/task/TwemproxyTask.java
--- a/monitor-service-middleware/src/main/java/com/monitor/middleware/redis/task/TwemproxyTask.java
View file @0037030
+++ b/monitor-service-middleware/src/main/java/com/monitor/middleware/redis/task/TwemproxyTask.java
View file @0037030
@@ -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 {} 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();