activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: Add some additional control over what is configured on the running broker.
Date Fri, 12 Jun 2015 18:27:01 GMT
Repository: activemq
Updated Branches:
  refs/heads/master 8cc5f597d -> d723d14ac


Add some additional control over what is configured on the running
broker.

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/d723d14a
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/d723d14a
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/d723d14a

Branch: refs/heads/master
Commit: d723d14acb4f87c312804cabe61c7786e971396d
Parents: 8cc5f59
Author: Timothy Bish <tabish121@gmail.com>
Authored: Fri Jun 12 14:26:04 2015 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Fri Jun 12 14:26:55 2015 -0400

----------------------------------------------------------------------
 .../activemq/transport/amqp/IDERunner.java      | 20 +++++++++++++++-----
 1 file changed, 15 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/d723d14a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
index ab64f21..7067605 100644
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/IDERunner.java
@@ -28,6 +28,8 @@ public class IDERunner {
 
     private static final String AMQP_TRANSFORMER = "jms";
     private static final boolean TRANSPORT_TRACE = true;
+    private static final boolean PERSISTENT = true;
+    private static final boolean CLIENT_CONNECT = false;
 
     public static void main(String[]args) throws Exception {
         BrokerService brokerService = new BrokerService();
@@ -40,15 +42,23 @@ public class IDERunner {
         KahaDBStore store = new KahaDBStore();
         store.setDirectory(new File("target/activemq-data/kahadb"));
 
-        brokerService.setStoreOpenWireVersion(10);
-        brokerService.setPersistenceAdapter(store);
+        if (PERSISTENT) {
+            brokerService.setStoreOpenWireVersion(10);
+            brokerService.setPersistenceAdapter(store);
+            brokerService.deleteAllMessages();
+        } else {
+            brokerService.setPersistent(false);
+        }
+
         brokerService.setUseJmx(false);
-        brokerService.deleteAllMessages();
+        brokerService.setAdvisorySupport(false);
 
         brokerService.start();
 
-        Connection connection = JMSClientContext.INSTANCE.createConnection(connector.getPublishableConnectURI());
-        connection.start();
+        if (CLIENT_CONNECT) {
+            Connection connection = JMSClientContext.INSTANCE.createConnection(connector.getPublishableConnectURI());
+            connection.start();
+        }
 
         brokerService.waitUntilStopped();
     }


Mime
View raw message