From bedb2078830cafe21db523c00706cd1357a63a48 Mon Sep 17 00:00:00 2001 From: gtully Date: Wed, 21 Jan 2015 22:35:49 +0000 Subject: [PATCH] reduce test duration, mem limits still reached as before and temp store utilised --- .../org/apache/activemq/broker/region/QueuePurgeTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java index c017e873ee..91209379ad 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java @@ -48,7 +48,7 @@ import org.slf4j.LoggerFactory; public class QueuePurgeTest extends CombinationTestSupport { private static final Logger LOG = LoggerFactory.getLogger(QueuePurgeTest.class); - private static final int NUM_TO_SEND = 40000; + private static final int NUM_TO_SEND = 20000; private final String MESSAGE_TEXT = new String(new byte[1024]); BrokerService broker; ConnectionFactory factory; @@ -131,12 +131,12 @@ public class QueuePurgeTest extends CombinationTestSupport { public void testRepeatedExpiryProcessingOfLargeQueue() throws Exception { applyBrokerSpoolingPolicy(); - final int exprityPeriod = 1000; - applyExpiryDuration(exprityPeriod); + final int expiryPeriod = 500; + applyExpiryDuration(expiryPeriod); createProducerAndSendMessages(NUM_TO_SEND); QueueViewMBean proxy = getProxyToQueueViewMBean(); LOG.info("waiting for expiry to kick in a bunch of times to verify it does not blow mem"); - Thread.sleep(10000); + Thread.sleep(5000); assertEquals("Queue size is has not changed " + proxy.getQueueSize(), NUM_TO_SEND, proxy.getQueueSize()); }