Author: jstrachan
Date: Tue Nov 28 07:38:01 2006
New Revision: 480095

URL: http://svn.apache.org/viewvc?view=rev&rev=480095
Log:
Fixed the test case so it actually fails! :)

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

Modified: 
incubator/activemq/branches/activemq-4.0/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.0/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java?view=diff&rev=480095&r1=480094&r2=480095
==============================================================================
--- 
incubator/activemq/branches/activemq-4.0/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java
 (original)
+++ 
incubator/activemq/branches/activemq-4.0/activemq-test-atomikos/src/test/java/org/apache/activemq/atomikos/XATest.java
 Tue Nov 28 07:38:01 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,13 @@
 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 url = "vm://localhost";
         String qName = "MyQueue";
         int timeout = 5;
         DefaultXidFactory xidFactory = new DefaultXidFactory();


Reply via email to