Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4558 Improving test assertions on IdempotentMirrored Ack Test

This commit is contained in:
Clebert Suconic 2024-01-16 12:25:22 -05:00
parent bc7e4639e0
commit 1fef332bea
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/soak-tests/src/test/java/org/apache/activemq/artemis/tests/soak/brokerConnection/mirror/IdempotentACKTest.java
View File

@ -295,6 +295,8 @@ public class IdempotentACKTest extends SoakTestBase {
// after all flushed messages, we should have 0 messages on both nodes // after all flushed messages, we should have 0 messages on both nodes
Wait.assertEquals(0, () -> getCount(simpleManagementDC1A, snfQueue)); Wait.assertEquals(0, () -> getCount(simpleManagementDC1A, snfQueue));
Wait.assertEquals(0, () -> getCount(simpleManagementDC2A, snfQueue));
Wait.assertEquals(0, () -> getCount(simpleManagementDC1A, QUEUE_NAME));
Wait.assertEquals(0, () -> getCount(simpleManagementDC2A, QUEUE_NAME)); Wait.assertEquals(0, () -> getCount(simpleManagementDC2A, QUEUE_NAME));
} }