(camel) 02/03: CAMEL-20477: avoid sharing reply queues

[orpiske]

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

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

commit df36d1609dafb461abb6dd5fadc6929ad9870b9c
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Mar 1 11:23:55 2024 +0100

    CAMEL-20477: avoid sharing reply queues
---
 .../jms/integration/spring/tx/JMSTXInOutPersistentQueueIT.java         | 3 ++-
 .../camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java   | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/integration/spring/tx/JMSTXInOutPersistentQueueIT.java
 
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/integration/spring/tx/JMSTXInOutPersistentQueueIT.java
index 7e45e6f375e..b631e1a76fd 100644
--- 
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/integration/spring/tx/JMSTXInOutPersistentQueueIT.java
+++ 
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/integration/spring/tx/JMSTXInOutPersistentQueueIT.java
@@ -70,7 +70,8 @@ public class JMSTXInOutPersistentQueueIT extends 
AbstractSpringJMSITSupport {
         return new RouteBuilder() {
             @Override
             public void configure() {
-                from("direct:start").to(ExchangePattern.InOut, 
"activemq:queue:JMSTXInOutPersistentQueueTest?replyTo=myReplies")
+                from("direct:start").to(ExchangePattern.InOut,
+                        
"activemq:queue:JMSTXInOutPersistentQueueTest?replyTo=JmsInOutPersistentReplyQueueTest.myReplies")
                         .to("mock:reply")
                         .process(exchange -> {
                             if (counter++ < 2) {
diff --git 
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java
 
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java
index 1c137405697..a93141b7132 100644
--- 
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java
+++ 
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsInOutPersistentReplyQueueTest.java
@@ -66,7 +66,8 @@ public class JmsInOutPersistentReplyQueueTest extends 
AbstractJMSTest {
             public void configure() {
                 from("seda:start")
                         .log("Sending ${body}")
-                        .to(ExchangePattern.InOut, 
"activemq:queue:JmsInOutPersistentReplyQueueTest?replyTo=myReplies")
+                        .to(ExchangePattern.InOut,
+                                
"activemq:queue:JmsInOutPersistentReplyQueueTest?replyTo=JmsInOutPersistentReplyQueueTest.myReplies")
                         // process the remainder of the route concurrently
                         .threads(5)
                         .log("Reply ${body}")