From 08393aa269f52e346048e611cb74d5602c566768 Mon Sep 17 00:00:00 2001
From: "Hiram R. Chirino" <chirino@apache.org>
Date: Mon, 14 Apr 2008 16:24:07 +0000
Subject: [PATCH] Added test case to trunk showing that AMQ-1438 is no longer
 an issue on the trunk.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@647882 13f79535-47bb-0310-9956-ffa450edef68
---
 .../ActiveMQXAConnectionFactoryTest.java      | 21 +++++++++++++++++++
 1 file changed, 21 insertions(+)

diff --git a/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java b/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java
index 980a35e0b8..1195708494 100644
--- a/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java
@@ -23,7 +23,10 @@ import javax.jms.Connection;
 import javax.jms.JMSException;
 import javax.jms.XAConnection;
 import javax.jms.XAQueueConnection;
+import javax.jms.XASession;
 import javax.jms.XATopicConnection;
+import javax.transaction.xa.XAException;
+import javax.transaction.xa.XAResource;
 
 import org.apache.activemq.broker.BrokerRegistry;
 import org.apache.activemq.broker.BrokerService;
@@ -95,6 +98,24 @@ public class ActiveMQXAConnectionFactoryTest extends CombinationTestSupport {
     public void testCreateTcpConnectionUsingKnownPort() throws Exception {
         assertCreateConnection("tcp://localhost:61610?wireFormat.tcpNoDelayEnabled=true");
     }
+    
+    public void testIsSameRM() throws URISyntaxException, JMSException, XAException {
+        
+        ActiveMQXAConnectionFactory cf1 = new ActiveMQXAConnectionFactory("vm://localhost?broker.persistent=false");
+        XAConnection connection1 = (XAConnection)cf1.createConnection();
+        XASession session1 = connection1.createXASession();
+        XAResource resource1 = session1.getXAResource();
+        
+        ActiveMQXAConnectionFactory cf2 = new ActiveMQXAConnectionFactory("vm://localhost?broker.persistent=false");
+        XAConnection connection2 = (XAConnection)cf2.createConnection();
+        XASession session2 = connection2.createXASession();
+        XAResource resource2 = session2.getXAResource();
+
+        assertTrue(resource1.isSameRM(resource2));
+        
+        connection1.close();
+        connection2.close();
+    }
 
     protected void assertCreateConnection(String uri) throws Exception {
         // Start up a broker with a tcp connector.