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);
}
}
Show replies by date