You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2015/06/12 20:27:01 UTC
activemq git commit: Add some additional control over what is
configured on the running broker.
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 <ta...@gmail.com>
Authored: Fri Jun 12 14:26:04 2015 -0400
Committer: Timothy Bish <ta...@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();
}