From 713603e65574b77578270b2c7a2fec412ed1fb71 Mon Sep 17 00:00:00 2001 From: snickersun Date: Wed, 8 Jan 2020 10:16:20 +0800 Subject: [PATCH] set Heartbeat AP00 and AP03 to sending Queue --- app/src/main/java/com/ic/protocol/service/KeepAlive.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/src/main/java/com/ic/protocol/service/KeepAlive.java b/app/src/main/java/com/ic/protocol/service/KeepAlive.java index e834f64f..96c7f781 100644 --- a/app/src/main/java/com/ic/protocol/service/KeepAlive.java +++ b/app/src/main/java/com/ic/protocol/service/KeepAlive.java @@ -284,8 +284,8 @@ public class KeepAlive extends AbstractConnectionService { Logger.i("onHeartAlarm"); // UpdateHeartBeatTimeout(); // if (this.reCycleTimes == 0 && this.currentReConnectInterval != 11){ - paramNettyConnection.send(protocolAPIHelper.genStringMessage("AP00",protocolAPIHelper.AP00(paramRuntime))); - paramNettyConnection.send(protocolAPIHelper.genStringMessage("heart",protocolAPIHelper.AP03(paramRuntime))); + ServiceUtil.offerQueue(protocolAPIHelper.genStringMessage("AP00",protocolAPIHelper.AP00(paramRuntime)),true); + ServiceUtil.offerQueue(protocolAPIHelper.genStringMessage("heart",protocolAPIHelper.AP03(paramRuntime))); // } } -- 2.17.1