diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 20503e4b39447c3b1f6e0597ea89ec6a98c83964..2176b9f5aa9c59ddb6ba7aa39122ae83a7a92c90 100644 --- a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java +++ b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java @@ -66,20 +66,20 @@ public class MQTTVerticle extends AbstractVerticle { .setTimeout(15000) .setMaxRetries(10) .setResetTimeout(30000); - circuitBreaker = CircuitBreaker.create("reconnect", vertx, options); + circuitBreaker = CircuitBreaker + .create("reconnect", vertx, options) + .retryPolicy(integer -> { + log.debug("integer: {}", integer); + long delay = ((integer + 1) * RECONNECT_DELAY); + log.info("Reconnecting in: {}ms", delay); + return delay; + }); client = MqttClient.create(vertx, clientOptions); client.pingResponseHandler(event -> log.debug("Pong received!")); client.closeHandler(event -> { log.warn("Connection lost!"); - circuitBreaker - .retryPolicy(integer -> { - log.debug("integer: {}", integer); - long delay = ((integer + 1) * RECONNECT_DELAY); - log.info("Reconnecting in: {}ms", delay); - return delay; - }) - .execute(this::connectMqtt); + circuitBreaker.execute(this::connectMqtt); }); }