Repository: activemq Updated Branches: refs/heads/trunk 7ce5be44d -> 189a75afd
reduce test duration, mem limits still reached as before and temp store utilised Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/bedb2078 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/bedb2078 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/bedb2078 Branch: refs/heads/trunk Commit: bedb2078830cafe21db523c00706cd1357a63a48 Parents: 7ce5be4 Author: gtully <[email protected]> Authored: Wed Jan 21 22:35:49 2015 +0000 Committer: gtully <[email protected]> Committed: Wed Jan 21 22:35:49 2015 +0000 ---------------------------------------------------------------------- .../org/apache/activemq/broker/region/QueuePurgeTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/bedb2078/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/QueuePurgeTest.java ---------------------------------------------------------------------- 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 c017e87..9120937 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()); }
