Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1EF5219D34 for ; Tue, 12 Apr 2016 14:15:06 +0000 (UTC) Received: (qmail 2415 invoked by uid 500); 12 Apr 2016 14:15:05 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 2374 invoked by uid 500); 12 Apr 2016 14:15:05 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 2365 invoked by uid 99); 12 Apr 2016 14:15:05 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 12 Apr 2016 14:15:05 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 9DC1DDFBA0; Tue, 12 Apr 2016 14:15:05 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: cshannon@apache.org To: commits@activemq.apache.org Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: activemq git commit: https://issues.apache.org/jira/browse/AMQ-5923 Date: Tue, 12 Apr 2016 14:15:05 +0000 (UTC) Repository: activemq Updated Branches: refs/heads/master cbad8babe -> 485fcafcd https://issues.apache.org/jira/browse/AMQ-5923 Updating tests to check prioritized messages as well Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/485fcafc Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/485fcafc Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/485fcafc Branch: refs/heads/master Commit: 485fcafcdfbb71b254977bbe5a670472aaaa4081 Parents: cbad8ba Author: Christopher L. Shannon (cshannon) Authored: Tue Apr 12 14:13:52 2016 +0000 Committer: Christopher L. Shannon (cshannon) Committed: Tue Apr 12 14:13:52 2016 +0000 ---------------------------------------------------------------------- .../AbstractPendingMessageCursorTest.java | 27 ++++++++++++++++++++ .../cursors/KahaDBPendingMessageCursorTest.java | 11 ++++++++ .../cursors/MemoryPendingMessageCursorTest.java | 8 ++++++ .../MultiKahaDBPendingMessageCursorTest.java | 7 +++++ 4 files changed, 53 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/485fcafc/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java index a31f402..5e4d07a 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursorTest.java @@ -20,6 +20,8 @@ import static org.junit.Assert.assertEquals; import java.io.IOException; import java.net.URI; +import java.util.Arrays; +import java.util.Collection; import java.util.concurrent.atomic.AtomicLong; import javax.jms.Connection; @@ -48,6 +50,7 @@ import org.apache.activemq.util.Wait.Condition; import org.junit.After; import org.junit.Before; import org.junit.Test; +import org.junit.runners.Parameterized.Parameters; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -67,6 +70,25 @@ public abstract class AbstractPendingMessageCursorTest extends AbstractStoreStat protected String defaultQueueName = "test.queue"; protected String defaultTopicName = "test.topic"; protected static int maxMessageSize = 1000; + protected boolean prioritizedMessages; + + @Parameters(name="prioritizedMessages={0}") + public static Collection data() { + return Arrays.asList(new Object[][] { + // use priority messages + {true}, + // don't use priority messages + {false} + }); + } + + /** + * @param prioritizedMessages + */ + public AbstractPendingMessageCursorTest(boolean prioritizedMessages) { + super(); + this.prioritizedMessages = prioritizedMessages; + } @Before public void startBroker() throws Exception { @@ -86,6 +108,7 @@ public abstract class AbstractPendingMessageCursorTest extends AbstractStoreStat PolicyEntry policy = new PolicyEntry(); policy.setTopicPrefetch(100); policy.setDurableTopicPrefetch(100); + policy.setPrioritizedMessages(isPrioritizedMessages()); PolicyMap pMap = new PolicyMap(); pMap.setDefaultEntry(policy); broker.setDestinationPolicy(pMap); @@ -114,6 +137,10 @@ public abstract class AbstractPendingMessageCursorTest extends AbstractStoreStat protected abstract void initPersistence(BrokerService brokerService) throws IOException; + protected boolean isPrioritizedMessages() { + return prioritizedMessages; + } + @Test public void testQueueMessageSize() throws Exception { AtomicLong publishedMessageSize = new AtomicLong(); http://git-wip-us.apache.org/repos/asf/activemq/blob/485fcafc/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/KahaDBPendingMessageCursorTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/KahaDBPendingMessageCursorTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/KahaDBPendingMessageCursorTest.java index 8a2c287..5cefc1b 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/KahaDBPendingMessageCursorTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/KahaDBPendingMessageCursorTest.java @@ -33,6 +33,8 @@ import org.apache.commons.io.FileUtils; import org.junit.Rule; import org.junit.Test; import org.junit.rules.TemporaryFolder; +import org.junit.runner.RunWith; +import org.junit.runners.Parameterized; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -42,6 +44,7 @@ import org.slf4j.LoggerFactory; * AMQ-5923 * */ +@RunWith(Parameterized.class) public class KahaDBPendingMessageCursorTest extends AbstractPendingMessageCursorTest { protected static final Logger LOG = LoggerFactory @@ -50,6 +53,13 @@ public class KahaDBPendingMessageCursorTest extends @Rule public TemporaryFolder dataFileDir = new TemporaryFolder(new File("target")); + /** + * @param prioritizedMessages + */ + public KahaDBPendingMessageCursorTest(boolean prioritizedMessages) { + super(prioritizedMessages); + } + @Override protected void setUpBroker(boolean clearDataDir) throws Exception { if (clearDataDir && dataFileDir.getRoot().exists()) @@ -159,4 +169,5 @@ public class KahaDBPendingMessageCursorTest extends verifyPendingStats(topic, subKey, 200, publishedMessageSize.get()); verifyStoreStats(topic, 0, 0); } + } http://git-wip-us.apache.org/repos/asf/activemq/blob/485fcafc/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MemoryPendingMessageCursorTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MemoryPendingMessageCursorTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MemoryPendingMessageCursorTest.java index 16d1919..257bbce 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MemoryPendingMessageCursorTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MemoryPendingMessageCursorTest.java @@ -27,6 +27,8 @@ import org.apache.activemq.broker.BrokerService; import org.apache.activemq.store.memory.MemoryPersistenceAdapter; import org.apache.activemq.util.SubscriptionKey; import org.junit.Test; +import org.junit.runner.RunWith; +import org.junit.runners.Parameterized; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -36,10 +38,16 @@ import org.slf4j.LoggerFactory; * AMQ-5748 * */ +@RunWith(Parameterized.class) public class MemoryPendingMessageCursorTest extends AbstractPendingMessageCursorTest { protected static final Logger LOG = LoggerFactory .getLogger(MemoryPendingMessageCursorTest.class); + + public MemoryPendingMessageCursorTest(boolean prioritizedMessages) { + super(prioritizedMessages); + } + @Override protected void initPersistence(BrokerService brokerService) throws IOException { broker.setPersistent(false); http://git-wip-us.apache.org/repos/asf/activemq/blob/485fcafc/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MultiKahaDBPendingMessageCursorTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MultiKahaDBPendingMessageCursorTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MultiKahaDBPendingMessageCursorTest.java index 9768980..9d8755f 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MultiKahaDBPendingMessageCursorTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/MultiKahaDBPendingMessageCursorTest.java @@ -34,6 +34,13 @@ import org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter; public class MultiKahaDBPendingMessageCursorTest extends KahaDBPendingMessageCursorTest { + /** + * @param prioritizedMessages + */ + public MultiKahaDBPendingMessageCursorTest(boolean prioritizedMessages) { + super(prioritizedMessages); + } + @Override protected void initPersistence(BrokerService brokerService) throws IOException {