diff options
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java b/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java index 15bc20c52d..94030f383e 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java +++ b/java/common/src/main/java/org/apache/qpid/framing/CompositeAMQDataBlock.java @@ -20,8 +20,7 @@ */ package org.apache.qpid.framing; -import java.io.DataOutputStream; -import java.io.IOException; +import org.apache.mina.common.ByteBuffer; public class CompositeAMQDataBlock extends AMQDataBlock implements EncodableAMQDataBlock { @@ -50,7 +49,7 @@ public class CompositeAMQDataBlock extends AMQDataBlock implements EncodableAMQD return frameSize; } - public void writePayload(DataOutputStream buffer) throws IOException + public void writePayload(ByteBuffer buffer) { for (int i = 0; i < _blocks.length; i++) { |