From 7c33bc499470e1410d8555c97b5fac4ccd0f9387 Mon Sep 17 00:00:00 2001 From: mapuo Date: Tue, 9 Jul 2019 17:51:03 +0300 Subject: [PATCH 1/2] remove hard sleep on reconnect --- src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 971523e..4bc7713 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -80,11 +80,6 @@ public class MQTTVerticle extends AbstractVerticle { client.pingResponseHandler(event -> log.debug("Pong received!")); client.closeHandler(event -> { log.warn("Connection lost!"); - try { - Thread.sleep(RECONNECT_DELAY * 2); - } catch (InterruptedException e) { - log.warn("Thread sleep interrupted!", e); - } circuitBreaker.execute(this::connectMqtt); }); } -- GitLab From 12e1b6148012fbfbcef2dd9f415d8ae8ac00c486 Mon Sep 17 00:00:00 2001 From: mapuo Date: Tue, 9 Jul 2019 18:54:35 +0300 Subject: [PATCH 2/2] use unique client id for the mqtt client --- src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java | 3 ++- 1 file changed, 2 insertions(+), 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 4bc7713..820409b 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -19,6 +19,7 @@ import org.springframework.stereotype.Component; import java.util.Arrays; import java.util.Objects; +import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; import java.util.function.BiConsumer; import java.util.function.Function; @@ -48,7 +49,7 @@ public class MQTTVerticle extends AbstractVerticle { .setUsername("micro") .setKeepAliveTimeSeconds(configuration.getKeepAliveInterval()) .setCleanSession(false) - .setClientId(configuration.getClientId()); + .setClientId("sys_micro_bridge_" + UUID.randomUUID().toString().replace("-", "")); } @Override -- GitLab