[jboss-cvs] JBoss Messaging SVN: r6080 - trunk/src/main/org/jboss/messaging/core/client/impl.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Fri Mar 13 12:25:27 EDT 2009


Author: jmesnil
Date: 2009-03-13 12:25:27 -0400 (Fri, 13 Mar 2009)
New Revision: 6080

Modified:
   trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionImpl.java
Log:
code cleanup

* removed useless state field
* removed unused ClientXAState class
* removed verbose error log in prepare(Xid)

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionImpl.java	2009-03-13 15:57:44 UTC (rev 6079)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionImpl.java	2009-03-13 16:25:27 UTC (rev 6080)
@@ -125,8 +125,6 @@
 
    private final boolean xa;
 
-   private final ClientXAState state = null;
-
    private final Executor executor;
 
    private volatile RemotingConnection remotingConnection;
@@ -1002,8 +1000,6 @@
       {
          SessionXAResponseMessage response = (SessionXAResponseMessage)channel.sendBlocking(packet);
 
-         log.error(response.getMessage() + " code " + response.getResponseCode());
-
          if (response.isError())
          {
             throw new XAException(response.getResponseCode());
@@ -1110,13 +1106,6 @@
    public void start(final Xid xid, final int flags) throws XAException
    {
       checkXA();
-      if (state != null)
-      {
-         log.error("XA operation failed Cannot start, session is already doing work in a transaction " + state.xid +
-                   "code:" +
-                   XAException.XAER_PROTO);
-         throw new XAException(XAException.XAER_PROTO);
-      }
       try
       {
          Packet packet;
@@ -1353,16 +1342,4 @@
          consumer.flushAcks();
       }
    }
-
-   class ClientXAState
-   {
-      final Xid xid;
-
-      int state;
-
-      public ClientXAState(final Xid xid)
-      {
-         this.xid = xid;
-      }
-   }
 }




More information about the jboss-cvs-commits mailing list