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();