Camel 4.7.0 update fix : OutgoingCamelTest testWithBeanDeclaringASimp…

…leProcessorThatForwardIncomingHeaders test
kamilchociej · Jul 16, 2024 · f76620c · f76620c
1 parent d30c175
commit f76620c
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...-camel/src/test/java/io/smallrye/reactive/messaging/camel/outgoing/OutgoingCamelTest.java b/...-camel/src/test/java/io/smallrye/reactive/messaging/camel/outgoing/OutgoingCamelTest.java
@@ -134,9 +134,9 @@ void testWithBeanDeclaringASimpleProcessorThatForwardIncomingHeaders() throws Ex
             final CompletableFuture<Exchange> completableFuture = CompletableFuture
                     .supplyAsync(
                             () -> camelContext().createConsumerTemplate()
-                                    .receive("nats:out?servers=127.0.0.1:7656&connectionTimeout=60000", 60000));
+                                    .receive("nats:out?servers=127.0.0.1:7656&connectionTimeout=50000", 60000));
             camelContext().createProducerTemplate()
-                    .asyncRequestBodyAndHeader("nats:in?servers=127.0.0.1:7656&connectionTimeout=60000", "a", HEADER_KEY,
+                    .asyncRequestBodyAndHeader("nats:in?servers=127.0.0.1:7656&connectionTimeout=50000", "a", HEADER_KEY,
                             HEADER_VALUE);
 
             final Exchange exchange = completableFuture.get(60, TimeUnit.SECONDS);
@@ -171,8 +171,8 @@ private MapBasedConfig getNatsConfig() {
         final String inPrefix = "mp.messaging.incoming.in.";
         final String outPrefix = "mp.messaging.outgoing.out.";
         final Map<String, Object> config = new HashMap<>();
-        config.putIfAbsent(inPrefix + "endpoint-uri", "nats:in?servers=127.0.0.1:7656&connectionTimeout=60000");
-        config.putIfAbsent(outPrefix + "endpoint-uri", "nats:out?servers=127.0.0.1:7656&connectionTimeout=60000");
+        config.putIfAbsent(inPrefix + "endpoint-uri", "nats:in?servers=127.0.0.1:7656&connectionTimeout=50000");
+        config.putIfAbsent(outPrefix + "endpoint-uri", "nats:out?servers=127.0.0.1:7656&connectionTimeout=50000");
         config.putIfAbsent(inPrefix + "connector", CamelConnector.CONNECTOR_NAME);
         config.putIfAbsent(outPrefix + "connector", CamelConnector.CONNECTOR_NAME);
         return new MapBasedConfig(config);