From f014d17104666bbc0794c2b615605a79e6dfe2a7 Mon Sep 17 00:00:00 2001 From: scottf Date: Tue, 8 Oct 2024 16:47:21 -0400 Subject: [PATCH] Use internal implementation timeout for direct calls --- src/test/java/io/nats/client/impl/JetStreamManagementTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/test/java/io/nats/client/impl/JetStreamManagementTests.java b/src/test/java/io/nats/client/impl/JetStreamManagementTests.java index 759a361fd..757b79f2d 100644 --- a/src/test/java/io/nats/client/impl/JetStreamManagementTests.java +++ b/src/test/java/io/nats/client/impl/JetStreamManagementTests.java @@ -1657,7 +1657,7 @@ public void testBatchDirectGetAlternatives() throws Exception { batch.add(msg); } }; - jsm.requestMessageBatch(tsc.stream, request, handler); + jsm.requestMessageBatch(tsc.stream, request, handler); assertEquals(3, batch.size()); MessageInfo last = batch.get(batch.size() - 1); assertEquals(0, last.getNumPending());