Try to parallelize the push message wait time

nats-io · May 8, 2024 · 598e3fe · 598e3fe
1 parent 855bbd2
commit 598e3fe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/nats/client/impl/MessageQueue.java b/src/main/java/io/nats/client/impl/MessageQueue.java
@@ -157,7 +157,7 @@ boolean push(NatsMessage msg, boolean internal) {
                 return this.queue.offer(msg);
             }
 
-            long timeoutLeft = Math.min(100, offerTimeoutMillis - (System.currentTimeMillis() - start));
+            long timeoutLeft = Math.max(100, offerTimeoutMillis - (System.currentTimeMillis() - start));
 
             if (!this.queue.offer(msg, timeoutLeft, TimeUnit.MILLISECONDS)) {
                 throw new IllegalStateException(OUTPUT_QUEUE_IS_FULL + queue.size());