Fixed the test case so it actually fails! :)

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/branches/activemq-4.0@480095 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-11-28 15:38:01 +00:00
parent f33ff0e9e4
commit c224394aa4
1 changed files with 8 additions and 2 deletions

View File

@ -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 @@ import junit.framework.TestCase;
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();