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