Repository: stratos Updated Branches: refs/heads/master d91935433 -> 781601177
Fixing ActiveMQ data directory in Test cases Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/78160117 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/78160117 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/78160117 Branch: refs/heads/master Commit: 781601177dca1c83128fef1fbc66b83dbf13cfdd Parents: d919354 Author: Akila Perera <[email protected]> Authored: Tue Jul 7 14:12:47 2015 +0530 Committer: Akila Perera <[email protected]> Committed: Wed Jul 8 11:53:39 2015 +0530 ---------------------------------------------------------------------- .../java/org/apache/stratos/messaging/test/AmqpSubscriberTest.java | 2 ++ .../apache/stratos/integration/tests/StratosTestServerManager.java | 2 ++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/78160117/components/org.apache.stratos.messaging/src/test/java/org/apache/stratos/messaging/test/AmqpSubscriberTest.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/test/java/org/apache/stratos/messaging/test/AmqpSubscriberTest.java b/components/org.apache.stratos.messaging/src/test/java/org/apache/stratos/messaging/test/AmqpSubscriberTest.java index e9ab86d..8c1e6eb 100644 --- a/components/org.apache.stratos.messaging/src/test/java/org/apache/stratos/messaging/test/AmqpSubscriberTest.java +++ b/components/org.apache.stratos.messaging/src/test/java/org/apache/stratos/messaging/test/AmqpSubscriberTest.java @@ -63,6 +63,8 @@ public class AmqpSubscriberTest { try { log.info("Initializing ActiveMQ..."); broker = new BrokerService(); + broker.setDataDirectory(AmqpSubscriberTest.class.getResource("/").getPath() + + File.separator + ".." + File.separator + "activemq-data"); broker.setBrokerName("testBroker"); broker.addConnector("tcp://localhost:61617"); } catch (Exception e) { http://git-wip-us.apache.org/repos/asf/stratos/blob/78160117/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/StratosTestServerManager.java ---------------------------------------------------------------------- diff --git a/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/StratosTestServerManager.java b/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/StratosTestServerManager.java index 765467c..e485d33 100755 --- a/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/StratosTestServerManager.java +++ b/products/stratos/modules/integration/src/test/java/org/apache/stratos/integration/tests/StratosTestServerManager.java @@ -75,6 +75,8 @@ public class StratosTestServerManager extends TestServerManager { long time1 = System.currentTimeMillis(); log.info("Starting ActiveMQ..."); BrokerService broker = new BrokerService(); + broker.setDataDirectory(StratosTestServerManager.class.getResource("/").getPath() + + File.separator + ".." + File.separator + "activemq-data"); broker.setBrokerName("testBroker"); broker.addConnector(ACTIVEMQ_BIND_ADDRESS); broker.start();
