diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2012-08-03 12:13:32 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2012-08-03 12:13:32 +0000 |
| commit | d43d1912b376322e27fdcda551a73f9ff5487972 (patch) | |
| tree | ce493e10baa95f44be8beb5778ce51783463196d /java/jca/src | |
| parent | 04877fec0c6346edec67072d7f2d247740cf2af5 (diff) | |
| download | qpid-python-d43d1912b376322e27fdcda551a73f9ff5487972.tar.gz | |
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
Diffstat (limited to 'java/jca/src')
| -rw-r--r-- | java/jca/src/main/java/org/apache/qpid/ra/QpidRAXAResource.java | 17 |
1 files changed, 15 insertions, 2 deletions
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<XAResource> getSiblings() + { + return ((AMQXAResource)_xaResource).getSiblings(); + } } |
