diff --git a/pom.xml b/pom.xml index bcdec8c..d987075 100644 --- a/pom.xml +++ b/pom.xml @@ -102,7 +102,7 @@ it.tdlight tdlight-java - 3.169.114 + 3.169.120 it.cavallium diff --git a/src/main/java/it/tdlight/tdlibsession/td/middle/client/AsyncTdMiddleEventBusClient.java b/src/main/java/it/tdlight/tdlibsession/td/middle/client/AsyncTdMiddleEventBusClient.java index cbe553f..6aa0655 100644 --- a/src/main/java/it/tdlight/tdlibsession/td/middle/client/AsyncTdMiddleEventBusClient.java +++ b/src/main/java/it/tdlight/tdlibsession/td/middle/client/AsyncTdMiddleEventBusClient.java @@ -72,7 +72,7 @@ public class AsyncTdMiddleEventBusClient extends AbstractVerticle implements Asy } } this.deliveryOptions = cluster.newDeliveryOpts().setLocalOnly(local); - this.deliveryOptionsWithTimeout = cluster.newDeliveryOpts().setLocalOnly(local).setSendTimeout(10000); + this.deliveryOptionsWithTimeout = cluster.newDeliveryOpts().setLocalOnly(local).setSendTimeout(30000); } public static Mono getAndDeployInstance(TdClusterManager clusterManager, String botAlias, String botAddress, boolean local) throws InitializationException { @@ -112,7 +112,7 @@ public class AsyncTdMiddleEventBusClient extends AbstractVerticle implements Asy this.initTime = System.currentTimeMillis(); CircuitBreaker startBreaker = CircuitBreaker.create("bot-" + botAddress + "-server-online-check-circuit-breaker", vertx, - new CircuitBreakerOptions().setMaxFailures(1).setMaxRetries(4).setTimeout(10000) + new CircuitBreakerOptions().setMaxFailures(1).setMaxRetries(4).setTimeout(30000) ) .retryPolicy(policy -> 4000L) .openHandler(closed -> { @@ -146,7 +146,7 @@ public class AsyncTdMiddleEventBusClient extends AbstractVerticle implements Asy .getEventBus() .request(botAddress + ".isWorking", EMPTY, deliveryOptionsWithTimeout, msg -> { if (msg.succeeded()) { - this.listen().then(this.pipe()).timeout(Duration.ofSeconds(10)).subscribe(v -> {}, future::fail, future::complete); + this.listen().then(this.pipe()).timeout(Duration.ofSeconds(30)).subscribe(v -> {}, future::fail, future::complete); } else { future.fail(msg.cause()); } diff --git a/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java b/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java index 082eceb..6b9d5ea 100644 --- a/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java +++ b/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java @@ -136,7 +136,7 @@ public class AsyncTdMiddleEventBusServer extends AbstractVerticle { }); logger.debug("Sending " + botAddress + ".readyToStart"); - cluster.getEventBus().send(botAddress + ".readyToStart", EMPTY, cluster.newDeliveryOpts().setSendTimeout(10000)); + cluster.getEventBus().send(botAddress + ".readyToStart", EMPTY, cluster.newDeliveryOpts().setSendTimeout(30000)); var clientDeadCheckThread = new Thread(() -> { Throwable ex = null; @@ -148,7 +148,7 @@ public class AsyncTdMiddleEventBusServer extends AbstractVerticle { .getEventBus() .request(botAddress + ".readyToStart", EMPTY, - cluster.newDeliveryOpts().setSendTimeout(10000), + cluster.newDeliveryOpts().setSendTimeout(30000), r -> promise.handle(r.mapEmpty()) ); promise.future().toCompletionStage().toCompletableFuture().join();