Adding logs

hornetq · May 4, 2012 · 790830c · 790830c
1 parent 171ff25
commit 790830c
Showing 1 changed file with 38 additions and 2 deletions.
diff --git a/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java b/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java
@@ -1351,7 +1351,7 @@ public void end(final Xid xid, final int flags) throws XAException
    {
       if (trace)
       {
-         log.trace("Calling end:: " + convert(xid));
+         log.trace("Calling end:: " + convert(xid) + ", flags=" + convertTXFlag(flags));
       }
 
       checkXA();
@@ -1639,7 +1639,7 @@ public void start(final Xid xid, final int flags) throws XAException
    {
       if (trace)
       {
-         log.trace("Calling start:: " + convert(xid) + " clientXID=" + xid + " flags = " + flags);
+         log.trace("Calling start:: " + convert(xid) + " clientXID=" + xid + " flags = " + convertTXFlag(flags));
       }
 
       checkXA();
@@ -2142,4 +2142,40 @@ private Object convert(Xid xid)
       return "xid=" + obj + ",clientXID=" + xid;
    }
 
+   private String convertTXFlag(final int flags)
+   {
+      if (flags == XAResource.TMSUSPEND)
+      {
+         return "SESS_XA_SUSPEND";
+      }
+      else if (flags == XAResource.TMSUCCESS)
+      {
+         return "TMSUCCESS";
+      }
+      else if (flags == XAResource.TMFAIL)
+      {
+         return "TMFAIL";
+      }
+      else
+      if (flags == XAResource.TMJOIN)
+      {
+         return "TMJOIN";
+      }
+      else if (flags == XAResource.TMRESUME)
+      {
+         return "TMRESUME";
+      }
+      else if (flags == XAResource.TMNOFLAGS)
+      {
+         // Don't need to flush since the previous end will have done this
+         return "TMNOFLAGS";
+      }
+      else
+      {
+         return "XAER_INVAL(" + flags + ")";
+      }
+
+   }
+
+
 }