NO-JIRA fixing intermittent test failure

This commit is contained in:
Clebert Suconic 2021-12-10 12:40:58 -05:00 committed by clebertsuconic
parent 158157260c
commit 1e89ce828c
1 changed files with 1 additions and 1 deletions

View File

@ -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));