From 3f1c8227dc27079a682944347e9f2432abf95a7c Mon Sep 17 00:00:00 2001 From: Maurice van Veen Date: Tue, 20 Aug 2024 11:03:34 +0200 Subject: [PATCH] Fix potential busy loop during reconnectMode Signed-off-by: Maurice van Veen --- src/main/java/io/nats/client/impl/NatsConnectionWriter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/io/nats/client/impl/NatsConnectionWriter.java b/src/main/java/io/nats/client/impl/NatsConnectionWriter.java index 4a1360c53..e5767d844 100644 --- a/src/main/java/io/nats/client/impl/NatsConnectionWriter.java +++ b/src/main/java/io/nats/client/impl/NatsConnectionWriter.java @@ -180,7 +180,7 @@ void sendMessageBatch(NatsMessage msg, DataPort dataPort, StatisticsCollector st @Override public void run() { Duration waitForMessage = Duration.ofMinutes(2); // This can be long since no one is sending - Duration reconnectWait = Duration.ofMillis(1); // This should be short, since we are trying to get the reconnect through + Duration reconnectWait = Duration.ofMillis(100); // This should be short, since we are trying to get the reconnect through try { dataPort = this.dataPortFuture.get(); // Will wait for the future to complete