Browse Source

heart触发pointlist时的bug修复。

Jay Lee 6 years ago
parent
commit
ae9f914ec7
1 changed files with 9 additions and 4 deletions
  1. 9 4
      collect/src/main/java/com/saga/thread/down/CollectThread.java

+ 9 - 4
collect/src/main/java/com/saga/thread/down/CollectThread.java

@@ -536,10 +536,15 @@ public class CollectThread extends Thread {
 			LogUtil.warn(key + " needGetPointList true ...");
 			int id = Constant.getID();
 			for (IServerManager server : this.serverList.values()) {
-				server.AppendToSend(address,
-						new Packet(rList[0] + ";" + rList[1] + ";" + "pointcount" + ";" + "" + ";" + id));
-				LogUtil.info(server.Name() + " AppendToSend:" + address + " " + rList[0] + ";" + rList[1] + ";"
-						+ "pointcount" + ";" + "" + ";" + id);
+				try {
+					server.AppendToSend(address,
+							new Packet(rList[0] + ";" + rList[1] + ";" + "pointcount" + ";" + "" + ";" + id));
+					LogUtil.info(server.Name() + " AppendToSend:" + address + " " + rList[0] + ";" + rList[1] + ";"
+							+ "pointcount" + ";" + "" + ";" + id);
+				} catch (Exception e) {
+					// TODO Auto-generated catch block
+
+				}
 			}
 			this.getPointList.put(key, System.currentTimeMillis());
 		}