moved start

nats-io · Oct 8, 2024 · d42a65b · d42a65b
1 parent f014d17
commit d42a65b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/nats/client/impl/NatsJetStreamManagement.java b/src/main/java/io/nats/client/impl/NatsJetStreamManagement.java
@@ -389,9 +389,9 @@ public void _requestMessageBatch(String streamName, MessageBatchGetRequest messa
             String requestSubject = prependPrefix(String.format(JSAPI_DIRECT_GET, streamName));
             conn.publish(requestSubject, replyTo, messageBatchGetRequest.serialize());
 
-            long start = System.currentTimeMillis();
             long maxTimeMillis = getTimeout().toMillis();
             long timeLeft = maxTimeMillis;
+            long start = System.currentTimeMillis();
             while (true) {
                 Message msg = sub.nextMessage(timeLeft);
                 if (msg == null) {