You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/11/28 16:40:32 UTC

svn commit: r480097 - /incubator/activemq/trunk/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java

Author: jstrachan
Date: Tue Nov 28 07:40:30 2006
New Revision: 480097

URL: http://svn.apache.org/viewvc?view=rev&rev=480097
Log:
Fixed the test case so it actually does fail - before the patch was applied

Modified:
    incubator/activemq/trunk/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java

Modified: incubator/activemq/trunk/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java?view=diff&rev=480097&r1=480096&r2=480097
==============================================================================
--- incubator/activemq/trunk/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java (original)
+++ incubator/activemq/trunk/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java Tue Nov 28 07:40:30 2006
@@ -18,6 +18,7 @@
 package org.apache.activemq.atomikos;
 
 import com.atomikos.datasource.xa.DefaultXidFactory;
+import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.ActiveMQXAConnectionFactory;
 import org.apache.activemq.command.ActiveMQQueue;
 
@@ -36,8 +37,12 @@
 public class XATest extends TestCase {
 
     public void testXA() throws Exception {
-        //String url = "tcp://localhost:61616";
-        String url = "vm://localhost";
+		BrokerService broker = new BrokerService();
+		broker.addConnector("tcp://localhost:61616");
+		broker.start();
+		
+	
+        String url = "tcp://localhost:61616";
         String qName = "MyQueue";
         int timeout = 5;
         DefaultXidFactory xidFactory = new DefaultXidFactory();