(camel) branch main updated: CAMEL-25496: Stabilize flaky NatsProducerReplyToTimeoutIT

[apupier]

This is an automated email from the ASF dual-hosted git repository.

apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new adb6d3bb82b4 CAMEL-25496: Stabilize flaky NatsProducerReplyToTimeoutIT
adb6d3bb82b4 is described below

commit adb6d3bb82b4ff45bcd00c5a75bb41ab463dd106
Author: Aurélien Pupier <apup...@ibm.com>
AuthorDate: Mon Oct 12 17:09:42 2026 +0200

    CAMEL-25496: Stabilize flaky NatsProducerReplyToTimeoutIT
    
    - Wait for NATS consumer to be active before sending request to avoid
      503 no responders CancellationException
    - Isolate subject URI to avoid collision with NatsProducerReplyToIT
    
    Co-authored-by: IBM Bob <b...@ibm.com>
    Signed-off-by: Aurélien Pupier <apup...@ibm.com>
---
 .../component/nats/integration/NatsProducerReplyToTimeoutIT.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-nats/src/test/java/org/apache/camel/component/nats/integration/NatsProducerReplyToTimeoutIT.java
 
b/components/camel-nats/src/test/java/org/apache/camel/component/nats/integration/NatsProducerReplyToTimeoutIT.java
index a82ebe698e23..eb1ddc8b4e78 100644
--- 
a/components/camel-nats/src/test/java/org/apache/camel/component/nats/integration/NatsProducerReplyToTimeoutIT.java
+++ 
b/components/camel-nats/src/test/java/org/apache/camel/component/nats/integration/NatsProducerReplyToTimeoutIT.java
@@ -28,13 +28,15 @@ import static org.junit.jupiter.api.Assertions.fail;
 public class NatsProducerReplyToTimeoutIT extends NatsITSupport {
 
     protected String startUri = "direct:start";
-    protected String middleUri = "nats:foo.middle?requestTimeout=50";
+    protected String middleUri = "nats:foo.middle.timeout?requestTimeout=50";
     protected String resultUri = "mock:result";
 
     protected String body1 = "Camel";
 
     @Test
     public void testReplyToTimeout() {
+        waitForNatsConsumers(1);
+
         try {
             template.requestBody(startUri, body1, String.class);
             fail("Should have thrown an exception");