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

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


The following commit(s) were added to refs/heads/main by this push:
     new 67d22f576d ARTEMIS-5336 Stabilize flaky test with Wait.assertEquals
67d22f576d is described below

commit 67d22f576dad7ddfdf62fcd753d1eeadabd89018
Author: Clebert Suconic <[email protected]>
AuthorDate: Fri Jun 13 08:48:04 2025 -0400

    ARTEMIS-5336 Stabilize flaky test with Wait.assertEquals
    
    Ensures ReeliveryPolicyTest::testCountersAreCorrectAfterSendToDLQ
    waits for queue/counter values to become 0
    after asynchronous processing.
---
 .../artemis/tests/integration/openwire/amq/RedeliveryPolicyTest.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/RedeliveryPolicyTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/RedeliveryPolicyTest.java
index 02e146f912..eadc309b27 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/RedeliveryPolicyTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/RedeliveryPolicyTest.java
@@ -506,8 +506,7 @@ public class RedeliveryPolicyTest extends BasicOpenWireTest 
{
       Wait.assertEquals(0, () -> queueControl.getMessageCount());
       session.close();
 
-      assertEquals(0L, queueControl.getPersistentSize());
-
+      Wait.assertEquals(0L, queueControl::getPersistentSize, 5000, 100);
    }
 
    @Test


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact


Reply via email to