From d723d14acb4f87c312804cabe61c7786e971396d Mon Sep 17 00:00:00 2001 From: Timothy Bish Date: Fri, 12 Jun 2015 14:26:04 -0400 Subject: [PATCH] Add some additional control over what is configured on the running broker. --- .../activemq/transport/amqp/IDERunner.java | 20 ++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) 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 ab64f2116e..70676056ec 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(); }