(camel) branch main updated: chore: fix BrowsableQueueTest queue accumulation across retries

[davsclaus]

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

davsclaus 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 3626194f5e31 chore: fix BrowsableQueueTest queue accumulation across 
retries
3626194f5e31 is described below

commit 3626194f5e3109a8580eed29d9329b0ef8154562
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sun Sep 6 10:19:32 2026 +0200

    chore: fix BrowsableQueueTest queue accumulation across retries
    
    Two tests shared queue "b" without consuming messages, causing accumulation
    on retries. Give testSendMessagesThenBrowseQueueNoMax its own queue "e" and
    drain all queues in @BeforeEach to prevent leftover messages affecting 
results.
    
    Co-Authored-By: Claude Sonnet 4.6 <nore...@anthropic.com>
    Signed-off-by: Claus Ibsen <claus.ib...@gmail.com>
---
 .../java/org/apache/camel/component/jms/BrowsableQueueTest.java  | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
 
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
index c69aec8b4201..0c60547d31c1 100644
--- 
a/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
+++ 
b/components/camel-jms/src/test/java/org/apache/camel/component/jms/BrowsableQueueTest.java
@@ -121,7 +121,7 @@ public class BrowsableQueueTest extends AbstractJMSTest {
 
     @Test
     public void testSendMessagesThenBrowseQueueNoMax() {
-        final String queueName = 
queueNameForClass("activemq:BrowsableQueueTest.b", this.getClass());
+        final String queueName = 
queueNameForClass("activemq:BrowsableQueueTest.e", this.getClass());
 
         // send some messages
         for (int i = 0; i < expectedBodies.length; i++) {
@@ -173,5 +173,12 @@ public class BrowsableQueueTest extends AbstractJMSTest {
         context = camelContextExtension.getContext();
         template = camelContextExtension.getProducerTemplate();
         consumer = camelContextExtension.getConsumerTemplate();
+
+        for (String suffix : new String[] { "b", "c", "d", "e" }) {
+            String q = queueNameForClass("activemq:BrowsableQueueTest." + 
suffix, getClass());
+            while (consumer.receiveNoWait(q) != null) {
+                // drain leftover messages from previous runs/retries
+            }
+        }
     }
 }