org.jboss.messaging.integration.transports.netty
Class ChannelBufferWrapper
java.lang.Object
org.jboss.messaging.integration.transports.netty.ChannelBufferWrapper
- All Implemented Interfaces:
- MessagingBuffer
public class ChannelBufferWrapper
- extends java.lang.Object
- implements MessagingBuffer
Wraps Netty ChannelBuffer
with MessagingBuffer
.
Because there's neither position()
nor limit()
in a Netty
buffer. ChannelBuffer#readerIndex()
and ChannelBuffer#writerIndex()
are used as position
and limit
of the buffer respectively
instead.
- Version:
- $Rev: 6429 $, $Date: 2009-04-15 05:54:59 +0100 (Wed, 15 Apr 2009) $
- Author:
- Trustin Lee, Jeff Mesnil, Tim Fox, Clebert Suconic
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ChannelBufferWrapper
public ChannelBufferWrapper(ChannelBuffer buffer)
- Parameters:
buffer
-
capacity
public int capacity()
- Specified by:
capacity
in interface MessagingBuffer
clear
public void clear()
- Specified by:
clear
in interface MessagingBuffer
readable
public boolean readable()
- Specified by:
readable
in interface MessagingBuffer
readableBytes
public int readableBytes()
- Specified by:
readableBytes
in interface MessagingBuffer
readByte
public byte readByte()
- Specified by:
readByte
in interface MessagingBuffer
readBytes
public void readBytes(byte[] dst,
int dstIndex,
int length)
- Specified by:
readBytes
in interface MessagingBuffer
readBytes
public void readBytes(byte[] dst)
- Specified by:
readBytes
in interface MessagingBuffer
readerIndex
public int readerIndex()
- Specified by:
readerIndex
in interface MessagingBuffer
readerIndex
public void readerIndex(int readerIndex)
- Specified by:
readerIndex
in interface MessagingBuffer
readInt
public int readInt()
- Specified by:
readInt
in interface MessagingBuffer
readLong
public long readLong()
- Specified by:
readLong
in interface MessagingBuffer
readShort
public short readShort()
- Specified by:
readShort
in interface MessagingBuffer
readUnsignedByte
public short readUnsignedByte()
- Specified by:
readUnsignedByte
in interface MessagingBuffer
readUnsignedShort
public int readUnsignedShort()
- Specified by:
readUnsignedShort
in interface MessagingBuffer
resetReaderIndex
public void resetReaderIndex()
- Specified by:
resetReaderIndex
in interface MessagingBuffer
resetWriterIndex
public void resetWriterIndex()
- Specified by:
resetWriterIndex
in interface MessagingBuffer
setIndex
public void setIndex(int readerIndex,
int writerIndex)
- Specified by:
setIndex
in interface MessagingBuffer
setInt
public void setInt(int index,
int value)
- Specified by:
setInt
in interface MessagingBuffer
writable
public boolean writable()
- Specified by:
writable
in interface MessagingBuffer
writableBytes
public int writableBytes()
- Specified by:
writableBytes
in interface MessagingBuffer
writeByte
public void writeByte(byte value)
- Specified by:
writeByte
in interface MessagingBuffer
writeBytes
public void writeBytes(byte[] src,
int srcIndex,
int length)
- Specified by:
writeBytes
in interface MessagingBuffer
writeBytes
public void writeBytes(MessagingBuffer src,
int srcIndex,
int length)
- Specified by:
writeBytes
in interface MessagingBuffer
writeBytes
public void writeBytes(byte[] src)
- Specified by:
writeBytes
in interface MessagingBuffer
writeInt
public void writeInt(int value)
- Specified by:
writeInt
in interface MessagingBuffer
writeLong
public void writeLong(long value)
- Specified by:
writeLong
in interface MessagingBuffer
writerIndex
public int writerIndex()
- Specified by:
writerIndex
in interface MessagingBuffer
writerIndex
public void writerIndex(int writerIndex)
- Specified by:
writerIndex
in interface MessagingBuffer
writeShort
public void writeShort(short value)
- Specified by:
writeShort
in interface MessagingBuffer
array
public byte[] array()
- Specified by:
array
in interface MessagingBuffer
readBoolean
public boolean readBoolean()
- Specified by:
readBoolean
in interface MessagingBuffer
readChar
public char readChar()
- Specified by:
readChar
in interface MessagingBuffer
readDouble
public double readDouble()
- Specified by:
readDouble
in interface MessagingBuffer
readFloat
public float readFloat()
- Specified by:
readFloat
in interface MessagingBuffer
readNullableSimpleString
public SimpleString readNullableSimpleString()
- Specified by:
readNullableSimpleString
in interface MessagingBuffer
readNullableString
public java.lang.String readNullableString()
- Specified by:
readNullableString
in interface MessagingBuffer
readSimpleString
public SimpleString readSimpleString()
- Specified by:
readSimpleString
in interface MessagingBuffer
readString
public java.lang.String readString()
- Specified by:
readString
in interface MessagingBuffer
readUTF
public java.lang.String readUTF()
throws java.lang.Exception
- Specified by:
readUTF
in interface MessagingBuffer
- Throws:
java.lang.Exception
writeBoolean
public void writeBoolean(boolean val)
- Specified by:
writeBoolean
in interface MessagingBuffer
writeChar
public void writeChar(char val)
- Specified by:
writeChar
in interface MessagingBuffer
writeDouble
public void writeDouble(double val)
- Specified by:
writeDouble
in interface MessagingBuffer
writeFloat
public void writeFloat(float val)
- Specified by:
writeFloat
in interface MessagingBuffer
writeNullableSimpleString
public void writeNullableSimpleString(SimpleString val)
- Specified by:
writeNullableSimpleString
in interface MessagingBuffer
writeNullableString
public void writeNullableString(java.lang.String val)
- Specified by:
writeNullableString
in interface MessagingBuffer
writeSimpleString
public void writeSimpleString(SimpleString val)
- Specified by:
writeSimpleString
in interface MessagingBuffer
writeString
public void writeString(java.lang.String val)
- Specified by:
writeString
in interface MessagingBuffer
writeUTF
public void writeUTF(java.lang.String utf)
throws java.lang.Exception
- Specified by:
writeUTF
in interface MessagingBuffer
- Throws:
java.lang.Exception
getUnderlyingBuffer
public java.lang.Object getUnderlyingBuffer()
- Specified by:
getUnderlyingBuffer
in interface MessagingBuffer
Copyright © 2006 JBoss Inc. All Rights Reserved.