NO-JIRA fixing MessagesExpiredPagingTest

There is a reference expiring in one hour. It should not leave page mode.
This is about still flowing messages, not leaving page mode.
This commit is contained in:
Clebert Suconic 2022-03-22 09:15:06 -04:00
parent 603462a1a5
commit 49276ae633

View File

@ -184,7 +184,6 @@ public class MessagesExpiredPagingTest extends ActiveMQTestBase {
for (int i = 0; i < numberOfMessages; i++) {
if (i > 0 && i % pagingInterval == 0) {
for (Consumer c : consumers) {
Wait.assertFalse(queues[0].getPagingStore()::isPaging, 5000, 100);
producer.setTimeToLive(TimeUnit.HOURS.toMillis(1));
producer.send(session.createTextMessage("hello" + extraBody));
Wait.assertTrue(() -> c.consumedDelta.get() > 0);