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

Author: clebert.suconic(a)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); } }