From 1c0de6bda4dd2dd83771a33cb8ccb4c0701cbbcb Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Fri, 1 Sep 2006 00:00:49 +0000 Subject: [PATCH] implement toByteSequence on direct byte buffers too.. needed for http://issues.apache.org/activemq/browse/AMQ-907 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@439108 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activeio/packet/ByteBufferPacket.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/activeio/activeio-core/src/main/java/org/apache/activeio/packet/ByteBufferPacket.java b/activeio/activeio-core/src/main/java/org/apache/activeio/packet/ByteBufferPacket.java index 4d1ef2044a..1342715772 100644 --- a/activeio/activeio-core/src/main/java/org/apache/activeio/packet/ByteBufferPacket.java +++ b/activeio/activeio-core/src/main/java/org/apache/activeio/packet/ByteBufferPacket.java @@ -222,9 +222,13 @@ final public class ByteBufferPacket implements Packet { if( buffer.hasArray() ) { byte[] bs = buffer.array(); return new ByteSequence(bs, buffer.position(), buffer.remaining()); + } else { + byte[] bs = new byte[buffer.remaining()]; + int p = buffer.position(); + buffer.get(bs); + buffer.position(p); + return new ByteSequence(bs, 0, bs.length); } - // TODO: implement the direct case. - return null; } /**