[camel] branch main updated: (chores) camel-sjms: prevent tests from consuming data from other tests

[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


The following commit(s) were added to refs/heads/main by this push:
     new 9e05505d7ea (chores) camel-sjms: prevent tests from consuming data 
from other tests
9e05505d7ea is described below

commit 9e05505d7eaad98c55d67a09cae8aa9505253c72
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Wed Jun 7 11:30:40 2023 +0200

    (chores) camel-sjms: prevent tests from consuming data from other tests
---
 .../camel/component/sjms/producer/SjmsToDSendDynamicTest.java     | 8 ++++----
 .../org/apache/camel/component/sjms/producer/SjmsToDTest.java     | 8 ++++----
 .../camel/component/sjms/tx/TransactedTopicProducerTest.java      | 4 ++--
 3 files changed, 10 insertions(+), 10 deletions(-)

diff --git 
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java
 
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java
index cb998aeea90..80984cc96f4 100644
--- 
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java
+++ 
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java
@@ -26,17 +26,17 @@ public class SjmsToDSendDynamicTest extends JmsTestSupport {
 
     @Test
     public void testToD() {
-        template.sendBodyAndHeader("direct:start", "Hello bar", "where", 
"bar");
-        template.sendBodyAndHeader("direct:start", "Hello beer", "where", 
"beer");
+        template.sendBodyAndHeader("direct:start", "Hello bar", "where", 
"bar.SjmsToDSendDynamicTest");
+        template.sendBodyAndHeader("direct:start", "Hello beer", "where", 
"beer.SjmsToDSendDynamicTest");
 
         // there should only be one sjms endpoint
         long count = context.getEndpoints().stream().filter(e -> 
e.getEndpointUri().startsWith("sjms:")).count();
         assertEquals(1, count, "There should only be 1 sjms endpoint");
 
         // and the messages should be in the queues
-        String out = consumer.receiveBody("sjms:queue:bar", 2000, 
String.class);
+        String out = 
consumer.receiveBody("sjms:queue:bar.SjmsToDSendDynamicTest", 2000, 
String.class);
         assertEquals("Hello bar", out);
-        out = consumer.receiveBody("sjms:queue:beer", 2000, String.class);
+        out = consumer.receiveBody("sjms:queue:beer.SjmsToDSendDynamicTest", 
2000, String.class);
         assertEquals("Hello beer", out);
     }
 
diff --git 
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java
 
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java
index 95a323802a0..75c11a4096b 100644
--- 
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java
+++ 
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java
@@ -30,8 +30,8 @@ public class SjmsToDTest extends JmsTestSupport {
         getMockEndpoint("mock:bar").expectedBodiesReceived("Hello bar");
         getMockEndpoint("mock:beer").expectedBodiesReceived("Hello beer");
 
-        template.sendBodyAndHeader("direct:start", "Hello bar", "where", 
"bar");
-        template.sendBodyAndHeader("direct:start", "Hello beer", "where", 
"beer");
+        template.sendBodyAndHeader("direct:start", "Hello bar", "where", 
"bar.SjmsToDTest");
+        template.sendBodyAndHeader("direct:start", "Hello beer", "where", 
"beer.SjmsToDTest");
 
         MockEndpoint.assertIsSatisfied(context);
     }
@@ -44,8 +44,8 @@ public class SjmsToDTest extends JmsTestSupport {
                 // route message dynamic using toD
                 from("direct:start").toD("sjms:queue:${header.where}");
 
-                from("sjms:queue:bar").to("mock:bar");
-                from("sjms:queue:beer").to("mock:beer");
+                from("sjms:queue:bar.SjmsToDTest").to("mock:bar");
+                from("sjms:queue:beer.SjmsToDTest").to("mock:beer");
             }
         };
     }
diff --git 
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
 
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
index 4509c1e1b82..5649e524747 100644
--- 
a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
+++ 
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
@@ -71,7 +71,7 @@ public class TransactedTopicProducerTest extends 
JmsTestSupport {
             public void configure() {
 
                 from("direct:start")
-                        .to("sjms:topic:test.topic?transacted=true")
+                        
.to("sjms:topic:test.TransactedTopicProducerTest.topic?transacted=true")
                         .process(
                                 new Processor() {
                                     @Override
@@ -85,7 +85,7 @@ public class TransactedTopicProducerTest extends 
JmsTestSupport {
                                     }
                                 });
 
-                
from("sjms:topic:test.topic?durableSubscriptionName=bar&transacted=true")
+                
from("sjms:topic:test.TransactedTopicProducerTest.topic?durableSubscriptionName=bar&transacted=true")
                         .to("mock:result");
 
             }