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 in PagingTest

This commit is contained in:
Clebert Suconic 2022-10-23 12:16:23 -04:00
parent c199902cde
commit cffc06aec8
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/PagingTest.java
View File

@ -2492,7 +2492,7 @@ public class PagingTest extends ActiveMQTestBase {
} }
@Test @Test
public void testReceive() throws Exception { public void testReceiveImmediate() throws Exception {
clearDataRecreateServerDirs(); clearDataRecreateServerDirs();
Configuration config = createDefaultInVMConfig().setJournalSyncNonTransactional(false); Configuration config = createDefaultInVMConfig().setJournalSyncNonTransactional(false);
@ -2557,15 +2557,15 @@ public class PagingTest extends ActiveMQTestBase {
Wait.assertEquals(numberOfMessages, queue::getMessageCount); Wait.assertEquals(numberOfMessages, queue::getMessageCount);
int msgReceived = 0;
ClientSession sessionConsumer = sf.createSession(false, false, false); ClientSession sessionConsumer = sf.createSession(false, false, false);
sessionConsumer.start(); sessionConsumer.start();
ClientConsumer consumer = sessionConsumer.createConsumer(PagingTest.ADDRESS); ClientConsumer consumer = sessionConsumer.createConsumer(PagingTest.ADDRESS);
for (int msgCount = 0; msgCount < numberOfMessages; msgCount++) { for (int msgCount = 0; msgCount < numberOfMessages; msgCount++) {
logger.debug("Received {}", msgCount); logger.debug("Received {}", msgCount);
msgReceived++; ClientMessage msg = null;
Wait.assertTrue(() -> queue.peekFirstMessage() != null, 2000, 100); for (int retry = 0; retry < 10 && msg == null; retry++) {
ClientMessage msg = consumer.receive(1000); msg = consumer.receiveImmediate();
}
if (msg == null) { if (msg == null) {
logger.debug("It's null. leaving now"); logger.debug("It's null. leaving now");
sessionConsumer.commit(); sessionConsumer.commit();