This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch 2.19.x in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit a18486839547913481068b5e85b6c4ed70897d6b Author: Clebert Suconic <[email protected]> AuthorDate: Fri Dec 10 12:40:58 2021 -0500 NO-JIRA fixing intermittent test failure (cherry picked from commit 1e89ce828ca591507c01f7943694ffea88e3643c) --- .../artemis/tests/integration/client/TransactionalSendTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java index 18d0d15..5932f4a 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java @@ -64,7 +64,7 @@ public class TransactionalSendTest extends ActiveMQTestBase { Queue q = (Queue) server.getPostOffice().getBinding(queueA).getBindable(); Assert.assertEquals(0, getMessageCount(q)); session.commit(); - Assert.assertEquals(getMessageCount(q), numMessages); + Wait.assertEquals(numMessages, () -> getMessageCount(q)); // now send some more for (int i = 0; i < numMessages; i++) { cp.send(session.createMessage(false));
