You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2018/01/16 02:16:30 UTC
[04/11] james-project git commit: JAMES-2285 Rename JMSMailQueueTest
as legacy
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 <bt...@linagora.com>
Authored: Thu Jan 11 16:29:35 2018 +0700
Committer: benwa <bt...@linagora.com>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org