set Heartbeat AP00 and AP03 to sending Queue
authorsnickersun <snickersun@qq.com>
Wed, 8 Jan 2020 02:16:20 +0000 (10:16 +0800)
committersnickersun <snickersun@qq.com>
Wed, 8 Jan 2020 02:16:20 +0000 (10:16 +0800)
app/src/main/java/com/ic/protocol/service/KeepAlive.java

index e834f64..96c7f78 100644 (file)
@@ -284,8 +284,8 @@ public class KeepAlive extends AbstractConnectionService {
     Logger.i("onHeartAlarm");\r
 //    UpdateHeartBeatTimeout();\r
 //    if (this.reCycleTimes == 0 && this.currentReConnectInterval != 11){\r
-    paramNettyConnection.send(protocolAPIHelper.genStringMessage("AP00",protocolAPIHelper.AP00(paramRuntime)));\r
-    paramNettyConnection.send(protocolAPIHelper.genStringMessage("heart",protocolAPIHelper.AP03(paramRuntime)));\r
+    ServiceUtil.offerQueue(protocolAPIHelper.genStringMessage("AP00",protocolAPIHelper.AP00(paramRuntime)),true);\r
+    ServiceUtil.offerQueue(protocolAPIHelper.genStringMessage("heart",protocolAPIHelper.AP03(paramRuntime)));\r
  //    }\r
 \r
   }\r