changed for setting offset when buffers are fragmented

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@594881 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 3 insertions, 1 deletions

diff --git a/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java b/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java
index 76229a7ddd..474211ced2 100644
--- a/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java
+++ b/java/common/src/main/java/org/apache/qpidity/transport/codec/FragmentDecoder.java
@@ -97,11 +97,13 @@ public class FragmentDecoder extends AbstractDecoder
     protected void doGet(byte[] bytes)
     {
         int remaining = bytes.length;
+        int  offset = 0;
         while (remaining > 0)
         {
             preRead();
             int size = min(remaining, current.remaining());
-            current.get(bytes, 0, size);
+            current.get(bytes, offset, size);
+            offset += size;
             remaining -= size;
             postRead();
         }