Showing
1 changed file
with
8 additions
and
5 deletions
@@ -48,7 +48,7 @@ public class TwemproxyInfo { | @@ -48,7 +48,7 @@ public class TwemproxyInfo { | ||
48 | HashSet<String> relationRedis = new HashSet<>(); | 48 | HashSet<String> relationRedis = new HashSet<>(); |
49 | 49 | ||
50 | public TwemproxyInfo(String ip, int port, String info, HashSet<String> relateRedis) { | 50 | public TwemproxyInfo(String ip, int port, String info, HashSet<String> relateRedis) { |
51 | - | 51 | + DEBUG.info("TwemproxyInfo ip {} ,port {} ,info {},relateRedis {} ",ip,port,info,relateRedis); |
52 | this.info = info; | 52 | this.info = info; |
53 | 53 | ||
54 | this.ip = ip; | 54 | this.ip = ip; |
@@ -57,14 +57,17 @@ public class TwemproxyInfo { | @@ -57,14 +57,17 @@ public class TwemproxyInfo { | ||
57 | 57 | ||
58 | JsonNode infoJson = null; | 58 | JsonNode infoJson = null; |
59 | 59 | ||
60 | - try { | ||
61 | - infoJson = OBJECT_MAPPER.readTree(info); | 60 | + if(StringUtils.isNotBlank(info)){ |
61 | + try { | ||
62 | + infoJson = OBJECT_MAPPER.readTree(info); | ||
62 | 63 | ||
63 | - } catch (Exception e) { | 64 | + } catch (Exception e) { |
64 | 65 | ||
65 | - DEBUG.error("Failed to read twemproxy info {}...error {}", info, e); | 66 | + DEBUG.error("Failed to read twemproxy info {}...error {}", info, e); |
67 | + } | ||
66 | } | 68 | } |
67 | 69 | ||
70 | + | ||
68 | if (null != infoJson) { | 71 | if (null != infoJson) { |
69 | 72 | ||
70 | this.upTime = infoJson.get("uptime").getLongValue(); | 73 | this.upTime = infoJson.get("uptime").getLongValue(); |
-
Please register or login to post a comment