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 2022/08/31 07:15:11 UTC
[camel] 01/04: (chores) camel-jms: use unique resources in tests
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 28dca6c7a507c8090afe0a602affe65fd071e0c2
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Aug 30 17:29:17 2022 +0200
(chores) camel-jms: use unique resources in tests
---
.../camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java | 5 +++--
.../camel/component/jms/JmsSimpleRequestCustomReplyToTest.java | 6 +++---
2 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java
index 6e12eac01b4..d1c17d44c3c 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTemporaryCacheNoneTest.java
@@ -44,9 +44,10 @@ public class JmsRequestReplyTemporaryCacheNoneTest extends AbstractJMSTest {
context.addRoutes(new RouteBuilder() {
@Override
public void configure() {
- from("direct:start").to("activemq:queue:hello?replyToCacheLevelName=CACHE_NONE");
+ from("direct:start")
+ .to("activemq:queue:JmsRequestReplyTemporaryCacheNoneTest?replyToCacheLevelName=CACHE_NONE");
- from("activemq:queue:hello").process(exchange -> {
+ from("activemq:queue:JmsRequestReplyTemporaryCacheNoneTest").process(exchange -> {
exchange.getIn().setBody("Bye World");
assertNotNull(exchange.getIn().getHeader("JMSReplyTo"));
}).to("mock:result");
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java
index 605c4bd1e63..fe7c6532883 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestCustomReplyToTest.java
@@ -53,9 +53,9 @@ public class JmsSimpleRequestCustomReplyToTest extends AbstractJMSTest {
MockEndpoint result = getMockEndpoint("mock:result");
result.expectedMessageCount(1);
- Exchange out = template.request("activemq:queue:hello", exchange -> {
+ Exchange out = template.request("activemq:queue:JmsSimpleRequestCustomReplyToTest", exchange -> {
exchange.setPattern(ExchangePattern.InOnly);
- exchange.getIn().setHeader("MyReplyQeueue", "foo");
+ exchange.getIn().setHeader("MyReplyQeueue", "JmsSimpleRequestCustomReplyToTest.reply");
exchange.getIn().setBody("Hello World");
});
@@ -122,7 +122,7 @@ public class JmsSimpleRequestCustomReplyToTest extends AbstractJMSTest {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- from(componentName + ":queue:hello").process(exchange -> {
+ from(componentName + ":queue:JmsSimpleRequestCustomReplyToTest").process(exchange -> {
assertEquals("Hello World", exchange.getIn().getBody());
myReplyTo = exchange.getIn().getHeader("MyReplyQeueue", String.class);