jstrachan 2002/11/12 10:58:54
Modified: messenger/src/java/org/apache/commons/messenger
XACapableAdapter.java
Log:
added a warning if a non-XA Messenger is used inside an XA transaction
Revision Changes Path
1.2 +13 -0
jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messenger/XACapableAdapter.java
Index: XACapableAdapter.java
===================================================================
RCS file:
/home/cvs/jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messenger/XACapableAdapter.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- XACapableAdapter.java 8 Nov 2002 14:54:26 -0000 1.1
+++ XACapableAdapter.java 12 Nov 2002 18:58:54 -0000 1.2
@@ -14,6 +14,9 @@
import javax.transaction.Transaction;
import javax.transaction.xa.XAResource;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
/**
* <p><code>XACapableAdapter</code> is an adapter that implements
* XACapable for a given Messenger
@@ -24,6 +27,9 @@
*/
public class XACapableAdapter implements XACapable {
+ /** Logger */
+ private static final Log log = LogFactory.getLog(XACapableAdapter.class);
+
private Messenger messenger;
public XACapableAdapter(Messenger messenger) {
@@ -58,6 +64,13 @@
if (session instanceof XASession) {
XASession xaSession = (XASession) session;
return xaSession.getXAResource();
+ }
+ else {
+ log.warn(
+ "Messenger: " + messenger
+ + " cannot take part in an XA transaction as it does
not have an XASession."
+ + " session: " + session
+ );
}
return null;
}
--
To unsubscribe, e-mail: <mailto:commons-dev-unsubscribe@;jakarta.apache.org>
For additional commands, e-mail: <mailto:commons-dev-help@;jakarta.apache.org>
