Author: jstrachan
Date: Sun Jul 23 23:51:41 2006
New Revision: 424932
URL: http://svn.apache.org/viewvc?rev=424932&view=rev
Log:
used the new clientIDPrefix and made the code easier to run on Java 5
Modified:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/Main.java
Modified:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/Main.java
URL:
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/Main.java?rev=424932&r1=424931&r2=424932&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/Main.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/Main.java
Sun Jul 23 23:51:41 2006
@@ -54,14 +54,18 @@
broker = new BrokerService();
broker.setPersistent(false);
broker.setUseJmx(true);
+ broker.getManagementContext().setCreateConnector(false);
broker.setPlugins(new BrokerPlugin[] { new
ConnectionDotFilePlugin() });
broker.addConnector("tcp://localhost:61616");
broker.addConnector("stomp://localhost:61613");
}
broker.start();
+ ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory();
+ factory.setClientIDPrefix("testClient");
+
// lets create a dummy couple of consumers
- Connection connection = new
ActiveMQConnectionFactory().createConnection();
+ Connection connection = factory.createConnection();
connection.start();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer1 = session.createConsumer(new
ActiveMQQueue("Orders.IBM"));