[jboss-cvs] JBoss Messaging SVN: r6389 - branches/Branch_Temp_Clebert_LargeMessage/src/main/org/jboss/messaging/core/remoting/impl/wireformat.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-04-09 15:52:14 -0400 (Thu, 09 Apr 2009)
New Revision: 6389

Modified:
   branches/Branch_Temp_Clebert_LargeMessage/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendContinuationMessage.java
Log:
Fixing bug... (not final version yet.. just a debug)

Modified: branches/Branch_Temp_Clebert_LargeMessage/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendContinuationMessage.java
===================================================================
--- branches/Branch_Temp_Clebert_LargeMessage/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendContinuationMessage.java	2009-04-09 19:10:09 UTC (rev 6388)
+++ branches/Branch_Temp_Clebert_LargeMessage/src/main/org/jboss/messaging/core/remoting/impl/wireformat/SessionSendContinuationMessage.java	2009-04-09 19:52:14 UTC (rev 6389)
@@ -89,7 +89,7 @@
    @Override
    public int getRequiredBufferSize()
    {
-      return super.getRequiredBufferSize() + DataConstants.SIZE_BOOLEAN;
+      return SESSION_CONTINUATION_BASE_SIZE + bodyLength + DataConstants.SIZE_BOOLEAN;
    }
 
    @Override
@@ -104,7 +104,10 @@
    @Override
    public void decodeBody(final MessagingBuffer buffer)
    {
-      super.decodeBody(buffer);
+      bodyLength = buffer.readInt();
+      body = new byte[bodyLength];
+      buffer.readBytes(body);
+      continues = buffer.readBoolean();
       requiresResponse = buffer.readBoolean();
    }