You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/03/01 12:54:27 UTC
(camel) 02/03: CAMEL-20477: avoid sharing reply queues
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 <an...@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}")