Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

used the new clientIDPrefix and made the code easier to run on Java 5

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@424932 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-07-24 06:51:41 +00:00
parent 0094ff7269
commit 387805efeb
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/test/Main.java
View File

@ -54,14 +54,18 @@ public class Main {
broker = new BrokerService(); broker = new BrokerService();
broker.setPersistent(false); broker.setPersistent(false);
broker.setUseJmx(true); broker.setUseJmx(true);
broker.getManagementContext().setCreateConnector(false);
broker.setPlugins(new BrokerPlugin[] { new ConnectionDotFilePlugin() }); broker.setPlugins(new BrokerPlugin[] { new ConnectionDotFilePlugin() });
broker.addConnector("tcp://localhost:61616"); broker.addConnector("tcp://localhost:61616");
broker.addConnector("stomp://localhost:61613"); broker.addConnector("stomp://localhost:61613");
} }
broker.start(); broker.start();
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();
factory.setClientIDPrefix("testClient");
// lets create a dummy couple of consumers // lets create a dummy couple of consumers
Connection connection = new ActiveMQConnectionFactory().createConnection(); Connection connection = factory.createConnection();
connection.start(); connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer1 = session.createConsumer(new ActiveMQQueue("Orders.IBM")); MessageConsumer consumer1 = session.createConsumer(new ActiveMQQueue("Orders.IBM"));