[hornetq-commits] JBoss hornetq SVN: r9508 - trunk/src/main/org/hornetq/core/protocol/stomp.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-08-05 08:50:31 -0400 (Thu, 05 Aug 2010)
New Revision: 9508

Modified:
   trunk/src/main/org/hornetq/core/protocol/stomp/StompSession.java
Log:
STOMP

* fix the copy of a Core message's body to a Stomp frame (broken after r9484)

Modified: trunk/src/main/org/hornetq/core/protocol/stomp/StompSession.java
===================================================================
--- trunk/src/main/org/hornetq/core/protocol/stomp/StompSession.java	2010-08-04 20:26:46 UTC (rev 9507)
+++ trunk/src/main/org/hornetq/core/protocol/stomp/StompSession.java	2010-08-05 12:50:31 UTC (rev 9508)
@@ -91,10 +91,11 @@
             headers.put(Stomp.Headers.Message.SUBSCRIPTION, subscription.getID());
          }
          HornetQBuffer buffer = serverMessage.getBodyBuffer();
-         buffer.readerIndex(MessageImpl.BUFFER_HEADER_SPACE + DataConstants.SIZE_INT);
+
          int bodyPos = serverMessage.getEndOfBodyPosition() == -1 ? buffer.writerIndex()
-                                                                 : serverMessage.getEndOfBodyPosition();
+                                                                  : serverMessage.getEndOfBodyPosition();
          int size = bodyPos - buffer.readerIndex();
+         buffer.readerIndex(MessageImpl.BUFFER_HEADER_SPACE + DataConstants.SIZE_INT);
          byte[] data = new byte[size];
          if (serverMessage.containsProperty(Stomp.Headers.CONTENT_LENGTH) || serverMessage.getType() == Message.BYTES_TYPE)
          {