[camel] branch main updated: (chores) camel-paho: prevent test from consuming data from another test

[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 2699f84302c (chores) camel-paho: prevent test from consuming data from 
another test
2699f84302c is described below

commit 2699f84302c96e1b2fe445f860005b460beb2496
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Wed Jun 7 11:10:57 2023 +0200

    (chores) camel-paho: prevent test from consuming data from another test
---
 .../test/java/org/apache/camel/component/paho/PahoToDTest.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDTest.java
 
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDTest.java
index f3ad116014c..6d208b1a848 100644
--- 
a/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDTest.java
+++ 
b/components/camel-paho/src/test/java/org/apache/camel/component/paho/PahoToDTest.java
@@ -36,12 +36,12 @@ public class PahoToDTest extends PahoTestSupport {
     @Test
     public void testToD() throws Exception {
         MockEndpoint bar = getMockEndpoint("mock:bar");
-        bar.expectedBodiesReceived("Hello bar", null); // issue with Artemis
+        bar.expectedBodiesReceived("Hello bar");
         MockEndpoint beer = getMockEndpoint("mock:beer");
         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.PahoToDTest");
+        template.sendBodyAndHeader("direct:start", "Hello beer", "where", 
"beer.PahoToDTest");
 
         bar.assertIsSatisfied();
         beer.assertIsSatisfied();
@@ -58,8 +58,8 @@ public class PahoToDTest extends PahoTestSupport {
                 // route message dynamic using toD
                 from("direct:start").toD("paho:${header.where}");
 
-                from("paho:bar").to("mock:bar");
-                from("paho:beer").to("mock:beer");
+                from("paho:bar.PahoToDTest").to("mock:bar");
+                from("paho:beer.PahoToDTest").to("mock:beer");
             }
         };
     }