(camel) branch main updated: Attempt to reduce flakinees of PahoMqtt5 Integration Tests

[apupier]

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

apupier 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 22fa39c07464 Attempt to reduce flakinees of PahoMqtt5 Integration Tests
22fa39c07464 is described below

commit 22fa39c074645103f9d2b860bc176ab694fab2c6
Author: Aurélien Pupier <apup...@ibm.com>
AuthorDate: Fri Aug 28 09:32:26 2026 +0200

    Attempt to reduce flakinees of PahoMqtt5 Integration Tests
    
    use specific ids for endpoints to avoid potential collisions between
    tests and this kind of error:
    
    ```
    java.lang.AssertionError: mock://bar Received message count. Expected:
    <1> but was: <2>
            at 
org.apache.camel.component.mock.MockEndpoint.fail(MockEndpoint.java:2075)
            at 
org.apache.camel.component.mock.MockEndpoint.assertEquals(MockEndpoint.java:2010)
            at 
org.apache.camel.component.mock.MockEndpoint.doAssertIsSatisfied(MockEndpoint.java:498)
            at 
org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:476)
            at 
org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:466)
            at 
org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:265)
            at 
org.apache.camel.component.paho.mqtt5.integration.PahoMqtt5ToDIT.testToD(PahoMqtt5ToDIT.java:34)
    ```
    It is happening on different configurations on Jenkins CI. Not
    reproduced locally.
    
    Signed-off-by: Aurélien Pupier <apup...@ibm.com>
---
 .../component/paho/mqtt5/integration/PahoMqtt5ToDIT.java     | 12 ++++++------
 .../paho/mqtt5/integration/PahoMqtt5ToDSendDynamicIT.java    |  8 ++++----
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git 
a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDIT.java
 
b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDIT.java
index f53c0d375c12..9d8ea5cce29f 100644
--- 
a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDIT.java
+++ 
b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDIT.java
@@ -25,11 +25,11 @@ public class PahoMqtt5ToDIT extends PahoMqtt5ITSupport {
 
     @Test
     public void testToD() throws Exception {
-        getMockEndpoint("mock:bar").expectedBodiesReceived("Hello bar");
-        getMockEndpoint("mock:beer").expectedBodiesReceived("Hello beer");
+        
getMockEndpoint("mock:PahoMqtt5ToDIT-bar").expectedBodiesReceived("Hello bar");
+        
getMockEndpoint("mock:PahoMqtt5ToDIT-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", 
"PahoMqtt5ToDIT-bar");
+        template.sendBodyAndHeader("direct:start", "Hello beer", "where", 
"PahoMqtt5ToDIT-beer");
 
         MockEndpoint.assertIsSatisfied(context);
     }
@@ -45,8 +45,8 @@ public class PahoMqtt5ToDIT extends PahoMqtt5ITSupport {
                 // route message dynamic using toD
                 from("direct:start").toD("paho-mqtt5:${header.where}");
 
-                from("paho-mqtt5:bar").to("mock:bar");
-                from("paho-mqtt5:beer").to("mock:beer");
+                
from("paho-mqtt5:PahoMqtt5ToDIT-bar").to("mock:PahoMqtt5ToDIT-bar");
+                
from("paho-mqtt5:PahoMqtt5ToDIT-beer").to("mock:PahoMqtt5ToDIT-beer");
             }
         };
     }
diff --git 
a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDSendDynamicIT.java
 
b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDSendDynamicIT.java
index c18fa2390374..310c5aedded0 100644
--- 
a/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDSendDynamicIT.java
+++ 
b/components/camel-paho-mqtt5/src/test/java/org/apache/camel/component/paho/mqtt5/integration/PahoMqtt5ToDSendDynamicIT.java
@@ -26,17 +26,17 @@ public class PahoMqtt5ToDSendDynamicIT extends 
PahoMqtt5ITSupport {
 
     @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", 
"PahoMqtt5ToDSendDynamicIT-bar");
+        template.sendBodyAndHeader("direct:start", "Hello beer", "where", 
"PahoMqtt5ToDSendDynamicIT-beer");
 
         // there should only be one paho endpoint
         long count = context.getEndpoints().stream().filter(e -> 
e.getEndpointUri().startsWith("paho-mqtt5:")).count();
         assertEquals(1, count, "There should only be 1 paho endpoint");
 
         // and the messages should be in the queues
-        String out = consumer.receiveBody("paho-mqtt5:bar", 2000, 
String.class);
+        String out = 
consumer.receiveBody("paho-mqtt5:PahoMqtt5ToDSendDynamicIT-bar", 2000, 
String.class);
         assertEquals("Hello bar", out);
-        out = consumer.receiveBody("paho-mqtt5:beer", 2000, String.class);
+        out = 
consumer.receiveBody("paho-mqtt5:PahoMqtt5ToDSendDynamicIT-beer", 2000, 
String.class);
         assertEquals("Hello beer", out);
     }