1 files changed, 13 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java b/qpid/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java
index 098e3652ad..819446021e 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java
@@ -23,6 +23,8 @@ package org.apache.qpid.framing;
 import java.io.DataOutput;
 import java.io.IOException;
 
+import org.apache.qpid.transport.ByteBufferSender;
+
 public class CompositeAMQDataBlock extends AMQDataBlock implements EncodableAMQDataBlock
 {
 
@@ -58,6 +60,17 @@ public class CompositeAMQDataBlock extends AMQDataBlock implements EncodableAMQD
         }
     }
 
+    @Override
+    public long writePayload(final ByteBufferSender sender) throws IOException
+    {
+        long size = 0l;
+        for (int i = 0; i < _blocks.length; i++)
+        {
+            size += _blocks[i].writePayload(sender);
+        }
+        return size;
+    }
+
     public String toString()
     {
         if (_blocks == null)