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 <[email protected]> Authored: Fri Jun 12 14:26:04 2015 -0400 Committer: Timothy Bish <[email protected]> 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(); }
