From 3d2125538f23f973e8ac632644f8170a66da964e Mon Sep 17 00:00:00 2001 From: mapuo Date: Tue, 9 Jul 2019 15:40:00 +0300 Subject: [PATCH] initialize circuit breaker retry policy just once --- .../nynja/bridge/verticle/MQTTVerticle.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java b/src/main/java/biz/nynja/bridge/verticle/MQTTVerticle.java index 20503e4..2176b9f 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); }); } -- GitLab