diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 971523e3e4589bcc7997f4d39ed9e7d52d43af90..820409b50f40d60e7fe4b4cd56aa1f1a5f4207b3 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 @@ -80,11 +81,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); }); }