diff options
Diffstat (limited to 'qpid/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlock.java')
-rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlock.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlock.java b/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlock.java index c234a5e829..8f804bf2d6 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlock.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQDataBlock.java @@ -23,6 +23,8 @@ package org.apache.qpid.framing; import java.io.DataOutput; import java.io.IOException; +import org.apache.qpid.transport.ByteBufferSender; + /** * A data block represents something that has a size in bytes and the ability to write itself to a byte @@ -44,4 +46,6 @@ public abstract class AMQDataBlock implements EncodableAMQDataBlock */ public abstract void writePayload(DataOutput buffer) throws IOException; + public abstract long writePayload(ByteBufferSender sender) throws IOException; + } |