[hornetq-commits] JBoss hornetq SVN: r9035 - trunk/src/main/org/hornetq/core/client/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-03-31 12:48:00 -0400 (Wed, 31 Mar 2010)
New Revision: 9035

Modified:
   trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java
Log:
Fixing LargeMessage failover.
(the same way receiving a message doesn't represent workDone, receiving a largeMessage shouldn't represent workdone)

Modified: trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java	2010-03-31 16:47:34 UTC (rev 9034)
+++ trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java	2010-03-31 16:48:00 UTC (rev 9035)
@@ -767,8 +767,6 @@
 
       if (consumer != null)
       {
-         workDone();
-
          consumer.handleLargeMessage(message);
       }
    }
@@ -779,8 +777,6 @@
 
       if (consumer != null)
       {
-         workDone();
-
          consumer.handleLargeMessageContinuation(continuation);
       }
    }