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

ARTEMIS-2457 speed up ring q tests

This commit is contained in:
Justin Bertram 2019-08-26 08:43:15 -05:00 committed by Clebert Suconic
parent dde6862aed
commit 354430ce36
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RingQueueTest.java
View File

@ -182,14 +182,13 @@ public class RingQueueTest extends ActiveMQTestBase {
ClientMessage m0 = createTextMessage(clientSession, "hello0"); ClientMessage m0 = createTextMessage(clientSession, "hello0");
long time = System.currentTimeMillis(); long time = System.currentTimeMillis();
time += 3000; time += 500;
m0.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, time); m0.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, time);
producer.send(m0); producer.send(m0);
Wait.assertTrue(() -> queue.getScheduledCount() == 1, 2000, 100); Wait.assertTrue(() -> queue.getScheduledCount() == 1, 2000, 100);
Wait.assertTrue(() -> ((QueueImpl) queue).getMessageCountForRing() == 0, 2000, 100); Wait.assertTrue(() -> ((QueueImpl) queue).getMessageCountForRing() == 0, 2000, 100);
Thread.sleep(1500);
time = System.currentTimeMillis(); time = System.currentTimeMillis();
time += 3000; time += 500;
m0.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, time); m0.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, time);
producer.send(m0); producer.send(m0);
Wait.assertTrue(() -> queue.getScheduledCount() == 2, 2000, 100); Wait.assertTrue(() -> queue.getScheduledCount() == 2, 2000, 100);
@ -327,7 +326,7 @@ public class RingQueueTest extends ActiveMQTestBase {
ClientConsumer consumer = clientSession.createConsumer(qName); ClientConsumer consumer = clientSession.createConsumer(qName);
Wait.assertTrue(() -> queue.getDeliveringCount() == 1, 2000, 100); Wait.assertTrue(() -> queue.getDeliveringCount() == 1, 2000, 100);
consumer.close(); consumer.close();
Thread.sleep(3000); Wait.assertTrue(() -> queue.getDeliveringCount() == 0, 2000, 100);
Wait.assertTrue(() -> queue.getMessageCount() == 1, 2000, 100); Wait.assertTrue(() -> queue.getMessageCount() == 1, 2000, 100);
} }