JAMES-2285 Rename JMSMailQueueTest as legacy This is intended for a easier review, as I'm forced to keep the JMSMailQueue class for a couple of commits more... (ActiveMQ extends it)
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/b2bd1b4d Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/b2bd1b4d Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/b2bd1b4d Branch: refs/heads/master Commit: b2bd1b4d00c52e5e2d5613342e69c602872b49e8 Parents: b6feb58 Author: benwa <[email protected]> Authored: Thu Jan 11 16:29:35 2018 +0700 Committer: benwa <[email protected]> Committed: Mon Jan 15 17:06:31 2018 +0700 ---------------------------------------------------------------------- .../james/queue/jms/JMSMailQueueTest.java | 45 -------------------- .../james/queue/jms/LegacyJMSMailQueueTest.java | 45 ++++++++++++++++++++ 2 files changed, 45 insertions(+), 45 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/b2bd1b4d/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/JMSMailQueueTest.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/JMSMailQueueTest.java b/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/JMSMailQueueTest.java deleted file mode 100644 index 9933bbb..0000000 --- a/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/JMSMailQueueTest.java +++ /dev/null @@ -1,45 +0,0 @@ -package org.apache.james.queue.jms; - -import java.util.Arrays; - -import org.apache.activemq.broker.BrokerService; -import org.apache.activemq.broker.region.policy.PolicyEntry; -import org.apache.activemq.broker.region.policy.PolicyMap; -import org.junit.AfterClass; -import org.junit.BeforeClass; - -public class JMSMailQueueTest extends AbstractJMSMailQueueTest { - - private static BrokerService broker; - - @BeforeClass - public static void setUpBroker() throws Exception { - broker = createBroker(); - broker.start(); - } - - @AfterClass - public static void tearDownBroker() throws Exception { - if (broker != null) { - broker.stop(); - } - } - - protected static BrokerService createBroker() throws Exception { - BrokerService aBroker = new BrokerService(); - aBroker.setPersistent(false); - aBroker.setUseJmx(false); - aBroker.addConnector("tcp://127.0.0.1:61616"); - - // Enable priority support - PolicyMap pMap = new PolicyMap(); - PolicyEntry entry = new PolicyEntry(); - entry.setPrioritizedMessages(true); - entry.setQueue(QUEUE_NAME); - pMap.setPolicyEntries(Arrays.asList(entry)); - aBroker.setDestinationPolicy(pMap); - - return aBroker; - } - -} http://git-wip-us.apache.org/repos/asf/james-project/blob/b2bd1b4d/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/LegacyJMSMailQueueTest.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/LegacyJMSMailQueueTest.java b/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/LegacyJMSMailQueueTest.java new file mode 100644 index 0000000..82bf3e2 --- /dev/null +++ b/server/queue/queue-jms/src/test/java/org/apache/james/queue/jms/LegacyJMSMailQueueTest.java @@ -0,0 +1,45 @@ +package org.apache.james.queue.jms; + +import java.util.Arrays; + +import org.apache.activemq.broker.BrokerService; +import org.apache.activemq.broker.region.policy.PolicyEntry; +import org.apache.activemq.broker.region.policy.PolicyMap; +import org.junit.AfterClass; +import org.junit.BeforeClass; + +public class LegacyJMSMailQueueTest extends AbstractJMSMailQueueTest { + + private static BrokerService broker; + + @BeforeClass + public static void setUpBroker() throws Exception { + broker = createBroker(); + broker.start(); + } + + @AfterClass + public static void tearDownBroker() throws Exception { + if (broker != null) { + broker.stop(); + } + } + + protected static BrokerService createBroker() throws Exception { + BrokerService aBroker = new BrokerService(); + aBroker.setPersistent(false); + aBroker.setUseJmx(false); + aBroker.addConnector("tcp://127.0.0.1:61616"); + + // Enable priority support + PolicyMap pMap = new PolicyMap(); + PolicyEntry entry = new PolicyEntry(); + entry.setPrioritizedMessages(true); + entry.setQueue(QUEUE_NAME); + pMap.setPolicyEntries(Arrays.asList(entry)); + aBroker.setDestinationPolicy(pMap); + + return aBroker; + } + +} --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
