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

ARTEMIS-3464 Adding assertion to test

This commit is contained in:
Clebert Suconic 2021-09-13 15:07:53 -04:00
parent 2481a784f3
commit b31737d2fc
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/PagedMirrorTest.java
View File

@ -27,6 +27,7 @@ import javax.jms.Session;
import javax.jms.TextMessage;
import java.io.File;
import java.util.HashMap;
import java.util.HashSet;
import java.util.LinkedList;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
@ -151,6 +152,8 @@ public class PagedMirrorTest extends ActiveMQTestBase {
Wait.assertEquals(0, snf2::getMessageCount);
Wait.assertEquals(1, () -> acksCount(countJournalLocation), 5000, 1000);
HashSet<Integer> receivedIDs = new HashSet<>();
try (Connection consumeConnection = secondConsumeCF.createConnection()) {
Session consumeSession = consumeConnection.createSession(true, Session.SESSION_TRANSACTED);
Queue jmsQueue = consumeSession.createQueue("someQueue");
@ -161,8 +164,18 @@ public class PagedMirrorTest extends ActiveMQTestBase {
TextMessage message = (TextMessage) consumer.receive(6000);
Assert.assertNotNull(message);
Assert.assertNotEquals(ACK_I, message.getIntProperty("i"));
receivedIDs.add(message.getIntProperty("i"));
}
Assert.assertNull(consumer.receiveNoWait());
Assert.assertEquals(NUMBER_OF_MESSAGES - 1, receivedIDs.size());
for (int i = 0; i < NUMBER_OF_MESSAGES; i++) {
if (i != ACK_I) {
Assert.assertTrue(receivedIDs.contains(i));
}
}
}
}