You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2019/08/26 14:17:01 UTC
[activemq-artemis] 02/03: ARTEMIS-2457 speed up ring q tests
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 354430ce3681492c4e7226d96bba7b5cf878a40c
Author: Justin Bertram <jb...@apache.org>
AuthorDate: Mon Aug 26 08:43:15 2019 -0500
ARTEMIS-2457 speed up ring q tests
---
.../activemq/artemis/tests/integration/server/RingQueueTest.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RingQueueTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RingQueueTest.java
index 723b76e..7343b6b 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RingQueueTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/RingQueueTest.java
@@ -182,14 +182,13 @@ public class RingQueueTest extends ActiveMQTestBase {
ClientMessage m0 = createTextMessage(clientSession, "hello0");
long time = System.currentTimeMillis();
- time += 3000;
+ time += 500;
m0.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, time);
producer.send(m0);
Wait.assertTrue(() -> queue.getScheduledCount() == 1, 2000, 100);
Wait.assertTrue(() -> ((QueueImpl) queue).getMessageCountForRing() == 0, 2000, 100);
- Thread.sleep(1500);
time = System.currentTimeMillis();
- time += 3000;
+ time += 500;
m0.putLongProperty(Message.HDR_SCHEDULED_DELIVERY_TIME, time);
producer.send(m0);
Wait.assertTrue(() -> queue.getScheduledCount() == 2, 2000, 100);
@@ -327,7 +326,7 @@ public class RingQueueTest extends ActiveMQTestBase {
ClientConsumer consumer = clientSession.createConsumer(qName);
Wait.assertTrue(() -> queue.getDeliveringCount() == 1, 2000, 100);
consumer.close();
- Thread.sleep(3000);
+ Wait.assertTrue(() -> queue.getDeliveringCount() == 0, 2000, 100);
Wait.assertTrue(() -> queue.getMessageCount() == 1, 2000, 100);
}