Repository: activemq Updated Branches: refs/heads/trunk a09047294 -> d91bdc4cf
fix test failure on slow ci boxes Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/d91bdc4c Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/d91bdc4c Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/d91bdc4c Branch: refs/heads/trunk Commit: d91bdc4cfffc2301d41c9a388120c818650257d4 Parents: a090472 Author: Dejan Bosanac <[email protected]> Authored: Mon Dec 22 12:03:36 2014 +0100 Committer: Dejan Bosanac <[email protected]> Committed: Mon Dec 22 12:03:53 2014 +0100 ---------------------------------------------------------------------- .../src/test/java/org/apache/activemq/bugs/AMQ2584Test.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/d91bdc4c/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584Test.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584Test.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584Test.java index 413f3fc..b84b9ab 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584Test.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ2584Test.java @@ -81,7 +81,7 @@ public class AMQ2584Test extends org.apache.activemq.TestSupport { @Test(timeout = 120000) public void testSize() throws Exception { int messages = 1000; - CountDownLatch redeliveryConsumerLatch = new CountDownLatch((messages*3) -1); + CountDownLatch redeliveryConsumerLatch = new CountDownLatch((messages*3)); openConsumer(redeliveryConsumerLatch); assertEquals(0, broker.getAdminView().getStorePercentUsage()); @@ -101,7 +101,7 @@ public class AMQ2584Test extends org.apache.activemq.TestSupport { closeConsumer(); // consume from DLQ - final CountDownLatch received = new CountDownLatch(messages -1); + final CountDownLatch received = new CountDownLatch(messages); consumerConnection = (ActiveMQConnection) createConnection(); Session dlqSession = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageConsumer dlqConsumer = dlqSession.createConsumer(new ActiveMQQueue("ActiveMQ.DLQ"));
