org.jboss.messaging.integration.transports.netty
Class ChannelBufferWrapper

java.lang.Object
  extended by 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

Constructor Summary
ChannelBufferWrapper(ChannelBuffer buffer)
           
 
Method Summary
 byte[] array()
           
 int capacity()
           
 void clear()
           
 java.lang.Object getUnderlyingBuffer()
           
 boolean readable()
           
 int readableBytes()
           
 boolean readBoolean()
           
 byte readByte()
           
 void readBytes(byte[] dst)
           
 void readBytes(byte[] dst, int dstIndex, int length)
           
 char readChar()
           
 double readDouble()
           
 int readerIndex()
           
 void readerIndex(int readerIndex)
           
 float readFloat()
           
 int readInt()
           
 long readLong()
           
 SimpleString readNullableSimpleString()
           
 java.lang.String readNullableString()
           
 short readShort()
           
 SimpleString readSimpleString()
           
 java.lang.String readString()
           
 short readUnsignedByte()
           
 int readUnsignedShort()
           
 java.lang.String readUTF()
           
 void resetReaderIndex()
           
 void resetWriterIndex()
           
 void setIndex(int readerIndex, int writerIndex)
           
 void setInt(int index, int value)
           
 boolean writable()
           
 int writableBytes()
           
 void writeBoolean(boolean val)
           
 void writeByte(byte value)
           
 void writeBytes(byte[] src)
           
 void writeBytes(byte[] src, int srcIndex, int length)
           
 void writeBytes(MessagingBuffer src, int srcIndex, int length)
           
 void writeChar(char val)
           
 void writeDouble(double val)
           
 void writeFloat(float val)
           
 void writeInt(int value)
           
 void writeLong(long value)
           
 void writeNullableSimpleString(SimpleString val)
           
 void writeNullableString(java.lang.String val)
           
 int writerIndex()
           
 void writerIndex(int writerIndex)
           
 void writeShort(short value)
           
 void writeSimpleString(SimpleString val)
           
 void writeString(java.lang.String val)
           
 void writeUTF(java.lang.String utf)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ChannelBufferWrapper

public ChannelBufferWrapper(ChannelBuffer buffer)
Parameters:
buffer -
Method Detail

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.