From f4e6cf89966ec1d929a792c4df5e8b1071bcb055 Mon Sep 17 00:00:00 2001 From: h27279392 Date: Sun, 9 May 2021 03:53:25 +0800 Subject: [PATCH] Update HeartBeatTask.java Fixed heartbeat failed not working --- lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java b/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java index 0ce86a7..5e92c05 100644 --- a/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java +++ b/lib/src/main/java/ua/naiksoftware/stomp/HeartBeatTask.java @@ -140,7 +140,7 @@ private void checkServerHeartBeat() { if (serverHeartbeat > 0) { final long now = System.currentTimeMillis(); //use a forgiving boundary as some heart beats can be delayed or lost. - final long boundary = now - (3 * serverHeartbeat); + final long boundary = now - (1 * serverHeartbeat); //we need to check because the task could failed to abort if (lastServerHeartBeat < boundary) { Log.d(TAG, "It's a sad day ;( Server didn't send heart-beat on time. Last received at '" + lastServerHeartBeat + "' and now is '" + now + "'"); @@ -149,8 +149,8 @@ private void checkServerHeartBeat() { } } else { Log.d(TAG, "We were checking and server sent heart-beat on time. So well-behaved :)"); - lastServerHeartBeat = System.currentTimeMillis(); } + this.scheduleServerHeartBeatCheck(); } }