From 98b1ce01e72727dca363f8f262253e426a3e1157 Mon Sep 17 00:00:00 2001 From: mapuo Date: Tue, 9 Jul 2019 16:51:29 +0300 Subject: [PATCH 1/2] Revert "set mqtt clean session to be true" This reverts commit 7bb69fb3 --- src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 8ec1003..2176b9f 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -46,7 +46,7 @@ public class MQTTVerticle extends AbstractVerticle { clientOptions = new MqttClientOptions() .setAutoKeepAlive(keepAliveEnabled) .setKeepAliveTimeSeconds(configuration.getKeepAliveInterval()) - .setCleanSession(true) + .setCleanSession(false) .setClientId(configuration.getClientId()); } -- GitLab From 973a9e85d88ad3b7494013652011061b5231515a Mon Sep 17 00:00:00 2001 From: mapuo Date: Tue, 9 Jul 2019 17:01:36 +0300 Subject: [PATCH 2/2] set hard sleep on reconnect for at least 2 seconds --- src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 2176b9f..ddb07c6 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -79,6 +79,11 @@ public class MQTTVerticle extends AbstractVerticle { client.pingResponseHandler(event -> log.debug("Pong received!")); client.closeHandler(event -> { log.warn("Connection lost!"); + try { + Thread.sleep(2000); + } catch (InterruptedException e) { + log.warn("Thread sleep interrupted!", e); + } circuitBreaker.execute(this::connectMqtt); }); } -- GitLab