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

NO-JIRA fixing intermittent failure with a Wait call

This commit is contained in:
Clebert Suconic 2021-06-02 19:53:26 -04:00
parent c993b5a0e9
commit f380324ca3
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java
View File

@ -25,6 +25,7 @@ import org.apache.activemq.artemis.api.core.client.ServerLocator;
import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.Queue; import org.apache.activemq.artemis.core.server.Queue;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.activemq.artemis.tests.util.Wait;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -68,9 +69,9 @@ public class TransactionalSendTest extends ActiveMQTestBase {
for (int i = 0; i < numMessages; i++) { for (int i = 0; i < numMessages; i++) {
cp.send(session.createMessage(false)); cp.send(session.createMessage(false));
} }
Assert.assertEquals(numMessages, getMessageCount(q)); Wait.assertEquals(numMessages, q::getMessageCount);
session.commit(); session.commit();
Assert.assertEquals(numMessages * 2, getMessageCount(q)); Wait.assertEquals(numMessages * 2, q::getMessageCount);
session.close(); session.close();
} }
@ -94,9 +95,9 @@ public class TransactionalSendTest extends ActiveMQTestBase {
for (int i = 0; i < numMessages; i++) { for (int i = 0; i < numMessages; i++) {
cp.send(session.createMessage(false)); cp.send(session.createMessage(false));
} }
Assert.assertEquals(0, getMessageCount(q)); Wait.assertEquals(0, q::getMessageCount);
session.commit(); session.commit();
Assert.assertEquals(numMessages, getMessageCount(q)); Wait.assertEquals(numMessages, q::getMessageCount);
session.close(); session.close();
} }