activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r424932 - /incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/Main.java
Date Mon, 24 Jul 2006 06:51:42 GMT
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"));



Mime
View raw message