From d43d1912b376322e27fdcda551a73f9ff5487972 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Fri, 3 Aug 2012 12:13:32 +0000 Subject: QPID-3858: Updated branch - merged from trunk r.1368650 git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1368910 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/ra/QpidRAXAResource.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) (limited to 'java/jca/src') diff --git a/java/jca/src/main/java/org/apache/qpid/ra/QpidRAXAResource.java b/java/jca/src/main/java/org/apache/qpid/ra/QpidRAXAResource.java index 22b39792b1..37ae7f5514 100644 --- a/java/jca/src/main/java/org/apache/qpid/ra/QpidRAXAResource.java +++ b/java/jca/src/main/java/org/apache/qpid/ra/QpidRAXAResource.java @@ -21,10 +21,13 @@ package org.apache.qpid.ra; +import java.util.List; + import javax.transaction.xa.XAException; import javax.transaction.xa.XAResource; import javax.transaction.xa.Xid; +import org.apache.qpid.client.AMQXAResource; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -32,7 +35,7 @@ import org.slf4j.LoggerFactory; * QpidRAXAResource. * */ -public class QpidRAXAResource implements XAResource +public class QpidRAXAResource implements AMQXAResource { /** The logger */ private static final Logger _log = LoggerFactory.getLogger(QpidRAXAResource.class); @@ -192,7 +195,7 @@ public class QpidRAXAResource implements XAResource { _log.trace("isSameRM(" + xaRes + ")"); } - + return _xaResource.isSameRM(xaRes); } @@ -242,4 +245,14 @@ public class QpidRAXAResource implements XAResource return _xaResource.setTransactionTimeout(seconds); } + + public String getBrokerUUID() + { + return ((AMQXAResource)_xaResource).getBrokerUUID(); + } + + public List getSiblings() + { + return ((AMQXAResource)_xaResource).getSiblings(); + } } -- cgit v1.2.1