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

jbertram pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/artemis.git


The following commit(s) were added to refs/heads/main by this push:
     new 4534c3caf8 NO-JIRA fix flaky test
4534c3caf8 is described below

commit 4534c3caf851d6cb7f57d40f22d06c4132bcdb2a
Author: Justin Bertram <[email protected]>
AuthorDate: Mon Apr 13 12:14:48 2026 -0500

    NO-JIRA fix flaky test
---
 .../activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
index 1b67756e49..f19e179941 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
@@ -37,6 +37,7 @@ import java.util.concurrent.TimeUnit;
 import org.apache.activemq.artemis.api.core.RoutingType;
 import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.core.postoffice.Bindings;
+import org.apache.activemq.artemis.tests.util.Wait;
 import org.apache.qpid.jms.JmsConnectionFactory;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
@@ -336,8 +337,7 @@ public class JMSTopicConsumerTest extends 
JMSClientTestSupport {
 
          connection.close();
          latch.await(5, TimeUnit.SECONDS);
-         bindingsForAddress = 
server.getPostOffice().getBindingsForAddress(SimpleString.of(getTopicName()));
-         assertEquals(1, bindingsForAddress.getBindings().size());
+         Wait.assertEquals(1, () -> 
server.getPostOffice().getBindingsForAddress(SimpleString.of(getTopicName())).getBindings().size(),
 2000, 20);
       } finally {
          connection.close();
       }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to