public class ChannelBufferWrapper extends Object implements HornetQBuffer
| Modifier and Type | Field and Description |
|---|---|
protected org.jboss.netty.buffer.ChannelBuffer |
buffer |
| Constructor and Description |
|---|
ChannelBufferWrapper(org.jboss.netty.buffer.ChannelBuffer buffer) |
| Modifier and Type | Method and Description |
|---|---|
int |
capacity()
Returns the number of bytes this buffer can contain.
|
org.jboss.netty.buffer.ChannelBuffer |
channelBuffer()
Returns the underlying Netty's ChannelBuffer
|
void |
clear()
Sets the
readerIndex and writerIndex of this buffer to
0. |
HornetQBuffer |
copy()
Returns a copy of this buffer's readable bytes.
|
HornetQBuffer |
copy(int index,
int length)
Returns a copy of this buffer's sub-region.
|
void |
discardReadBytes()
Discards the bytes between the 0th index and
readerIndex. |
HornetQBuffer |
duplicate()
Returns a buffer which shares the whole region of this buffer.
|
byte |
getByte(int index)
Gets a byte at the specified absolute
index in this buffer. |
void |
getBytes(int index,
byte[] dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index. |
void |
getBytes(int index,
byte[] dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index. |
void |
getBytes(int index,
ByteBuffer dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index until the destination's position
reaches its limit. |
void |
getBytes(int index,
HornetQBuffer dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index until the destination becomes
non-writable. |
void |
getBytes(int index,
HornetQBuffer dst,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index. |
void |
getBytes(int index,
HornetQBuffer dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index. |
char |
getChar(int index)
Gets a char at the specified absolute
index in
this buffer. |
double |
getDouble(int index)
Gets a double at the specified absolute
index in
this buffer. |
float |
getFloat(int index)
Gets a float at the specified absolute
index in
this buffer. |
int |
getInt(int index)
Gets a 32-bit integer at the specified absolute
index in
this buffer. |
long |
getLong(int index)
Gets a 64-bit long integer at the specified absolute
index in
this buffer. |
short |
getShort(int index)
Gets a 16-bit short integer at the specified absolute
index in
this buffer. |
short |
getUnsignedByte(int index)
Gets an unsigned byte at the specified absolute
index in this
buffer. |
long |
getUnsignedInt(int index)
Gets an unsigned 32-bit integer at the specified absolute
index
in this buffer. |
int |
getUnsignedShort(int index)
Gets an unsigned 16-bit short integer at the specified absolute
index in this buffer. |
void |
markReaderIndex()
Marks the current
readerIndex in this buffer. |
void |
markWriterIndex()
Marks the current
writerIndex in this buffer. |
boolean |
readable()
Returns
true
if and only if (this.writerIndex - this.readerIndex) is greater
than 0. |
int |
readableBytes()
Returns the number of readable bytes which is equal to
(this.writerIndex - this.readerIndex). |
boolean |
readBoolean()
Gets a boolean at the current
readerIndex
and increases the readerIndex by 1 in this buffer. |
byte |
readByte()
Gets a byte at the current
readerIndex and increases
the readerIndex by 1 in this buffer. |
void |
readBytes(byte[] dst)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= dst.length). |
void |
readBytes(byte[] dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length). |
void |
readBytes(ByteBuffer dst)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex until the destination's position
reaches its limit, and increases the readerIndex by the
number of the transferred bytes. |
void |
readBytes(HornetQBuffer dst)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex until the destination becomes
non-writable, and increases the readerIndex by the number of the
transferred bytes. |
void |
readBytes(HornetQBuffer dst,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length). |
void |
readBytes(HornetQBuffer dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length). |
HornetQBuffer |
readBytes(int length)
Transfers this buffer's data to a newly created buffer starting at
the current
readerIndex and increases the readerIndex
by the number of the transferred bytes (= length). |
char |
readChar()
Gets a char at the current
readerIndex
and increases the readerIndex by 2 in this buffer. |
double |
readDouble()
Gets a double at the current
readerIndex
and increases the readerIndex by 8 in this buffer. |
int |
readerIndex()
Returns the
readerIndex of this buffer. |
void |
readerIndex(int readerIndex)
Sets the
readerIndex of this buffer. |
float |
readFloat()
Gets a float at the current
readerIndex
and increases the readerIndex by 4 in this buffer. |
int |
readInt()
Gets a 32-bit integer at the current
readerIndex
and increases the readerIndex by 4 in this buffer. |
long |
readLong()
Gets a 64-bit integer at the current
readerIndex
and increases the readerIndex by 8 in this buffer. |
SimpleString |
readNullableSimpleString()
Gets a SimpleString (potentially
null) at the current readerIndex |
String |
readNullableString()
Gets a String (potentially
null) at the current readerIndex |
short |
readShort()
Gets a 16-bit short integer at the current
readerIndex
and increases the readerIndex by 2 in this buffer. |
SimpleString |
readSimpleString()
Gets a non-null SimpleString at the current
readerIndex |
HornetQBuffer |
readSlice(int length)
Returns a new slice of this buffer's sub-region starting at the current
readerIndex and increases the readerIndex by the size
of the new slice (= length). |
String |
readString()
Gets a non-null String at the current
readerIndex |
short |
readUnsignedByte()
Gets an unsigned byte at the current
readerIndex and increases
the readerIndex by 1 in this buffer. |
long |
readUnsignedInt()
Gets an unsigned 32-bit integer at the current
readerIndex
and increases the readerIndex by 4 in this buffer. |
int |
readUnsignedShort()
Gets an unsigned 16-bit short integer at the current
readerIndex
and increases the readerIndex by 2 in this buffer. |
String |
readUTF()
Gets a UTF-8 String at the current
readerIndex |
void |
resetReaderIndex()
Repositions the current
readerIndex to the marked
readerIndex in this buffer. |
void |
resetWriterIndex()
Repositions the current
writerIndex to the marked
writerIndex in this buffer. |
void |
setByte(int index,
byte value)
Sets the specified byte at the specified absolute
index in this
buffer. |
void |
setBytes(int index,
byte[] src)
Transfers the specified source array's data to this buffer starting at
the specified absolute
index. |
void |
setBytes(int index,
byte[] src,
int srcIndex,
int length)
Transfers the specified source array's data to this buffer starting at
the specified absolute
index. |
void |
setBytes(int index,
ByteBuffer src)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index until the source buffer's position
reaches its limit. |
void |
setBytes(int index,
HornetQBuffer src)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index until the destination becomes
unreadable. |
void |
setBytes(int index,
HornetQBuffer src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index. |
void |
setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index. |
void |
setChar(int index,
char value)
Sets the specified char at the specified absolute
index in this buffer. |
void |
setDouble(int index,
double value)
Sets the specified double at the specified absolute
index in this buffer. |
void |
setFloat(int index,
float value)
Sets the specified float at the specified absolute
index in this buffer. |
void |
setIndex(int readerIndex,
int writerIndex)
Sets the
readerIndex and writerIndex of this buffer
in one shot. |
void |
setInt(int index,
int value)
Sets the specified 32-bit integer at the specified absolute
index in this buffer. |
void |
setLong(int index,
long value)
Sets the specified 64-bit long integer at the specified absolute
index in this buffer. |
void |
setShort(int index,
short value)
Sets the specified 16-bit short integer at the specified absolute
index in this buffer. |
void |
skipBytes(int length)
Increases the current
readerIndex by the specified
length in this buffer. |
HornetQBuffer |
slice()
Returns a slice of this buffer's readable bytes.
|
HornetQBuffer |
slice(int index,
int length)
Returns a slice of this buffer's sub-region.
|
ByteBuffer |
toByteBuffer()
Converts this buffer's readable bytes into a NIO buffer.
|
ByteBuffer |
toByteBuffer(int index,
int length)
Converts this buffer's sub-region into a NIO buffer.
|
boolean |
writable()
Returns
true
if and only if (this.capacity - this.writerIndex) is greater
than 0. |
int |
writableBytes()
Returns the number of writable bytes which is equal to
(this.capacity - this.writerIndex). |
void |
writeBoolean(boolean val)
Sets the specified boolean at the current
writerIndex |
void |
writeByte(byte value)
Sets the specified byte at the current
writerIndex
and increases the writerIndex by 1 in this buffer. |
void |
writeBytes(byte[] src)
Transfers the specified source array's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= src.length). |
void |
writeBytes(byte[] src,
int srcIndex,
int length)
Transfers the specified source array's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length). |
void |
writeBytes(ByteBuffer src)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex until the source buffer's position
reaches its limit, and increases the writerIndex by the
number of the transferred bytes. |
void |
writeBytes(HornetQBuffer src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length). |
void |
writeBytes(HornetQBuffer src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the current
writerIndex and increases the writerIndex
by the number of the transferred bytes (= length). |
void |
writeChar(char chr)
Sets the specified char at the current
writerIndex
and increases the writerIndex by 2 in this buffer. |
void |
writeDouble(double value)
Sets the specified double at the current
writerIndex
and increases the writerIndex by 8 in this buffer. |
void |
writeFloat(float value)
Sets the specified float at the current
writerIndex
and increases the writerIndex by 4 in this buffer. |
void |
writeInt(int value)
Sets the specified 32-bit integer at the current
writerIndex
and increases the writerIndex by 4 in this buffer. |
void |
writeLong(long value)
Sets the specified 64-bit long integer at the current
writerIndex and increases the writerIndex by 8
in this buffer. |
void |
writeNullableSimpleString(SimpleString val)
Sets the specified SimpleString (potentially
null) at the current writerIndex |
void |
writeNullableString(String val)
Sets the specified String (potentially
null) at the current writerIndex |
int |
writerIndex()
Returns the
writerIndex of this buffer. |
void |
writerIndex(int writerIndex)
Sets the
writerIndex of this buffer. |
void |
writeShort(short value)
Sets the specified 16-bit short integer at the current
writerIndex and increases the writerIndex by 2
in this buffer. |
void |
writeSimpleString(SimpleString val)
Sets the specified non-null SimpleString at the current
writerIndex |
void |
writeString(String val)
Sets the specified non-null String at the current
writerIndex |
void |
writeUTF(String utf)
Sets the specified UTF-8 String at the current
writerIndex |
public ChannelBufferWrapper(org.jboss.netty.buffer.ChannelBuffer buffer)
public boolean readBoolean()
HornetQBufferreaderIndex
and increases the readerIndex by 1 in this buffer.readBoolean in interface HornetQBufferpublic SimpleString readNullableSimpleString()
HornetQBuffernull) at the current readerIndexreadNullableSimpleString in interface HornetQBufferpublic String readNullableString()
HornetQBuffernull) at the current readerIndexreadNullableString in interface HornetQBufferpublic SimpleString readSimpleString()
HornetQBufferreaderIndexreadSimpleString in interface HornetQBufferpublic String readString()
HornetQBufferreaderIndexreadString in interface HornetQBufferpublic String readUTF()
HornetQBufferreaderIndexreadUTF in interface HornetQBufferpublic void writeBoolean(boolean val)
HornetQBufferwriterIndexwriteBoolean in interface HornetQBufferpublic void writeNullableSimpleString(SimpleString val)
HornetQBuffernull) at the current writerIndexwriteNullableSimpleString in interface HornetQBufferpublic void writeNullableString(String val)
HornetQBuffernull) at the current writerIndexwriteNullableString in interface HornetQBufferpublic void writeSimpleString(SimpleString val)
HornetQBufferwriterIndexwriteSimpleString in interface HornetQBufferpublic void writeString(String val)
HornetQBufferwriterIndexwriteString in interface HornetQBufferpublic void writeUTF(String utf)
HornetQBufferwriterIndexwriteUTF in interface HornetQBufferpublic int capacity()
HornetQBuffercapacity in interface HornetQBufferpublic org.jboss.netty.buffer.ChannelBuffer channelBuffer()
HornetQBufferchannelBuffer in interface HornetQBufferpublic void clear()
HornetQBufferreaderIndex and writerIndex of this buffer to
0.
This method is identical to setIndex(0, 0).
Please note that the behavior of this method is different
from that of NIO buffer, which sets the limit to
the capacity of the buffer.
clear in interface HornetQBufferpublic HornetQBuffer copy()
HornetQBufferbuf.copy(buf.readerIndex(), buf.readableBytes()).
This method does not modify readerIndex or writerIndex of
this buffer.copy in interface HornetQBufferpublic HornetQBuffer copy(int index, int length)
HornetQBufferreaderIndex or writerIndex of
this buffer.copy in interface HornetQBufferpublic void discardReadBytes()
HornetQBufferreaderIndex.
It moves the bytes between readerIndex and writerIndex
to the 0th index, and sets readerIndex and writerIndex
to 0 and oldWriterIndex - oldReaderIndex respectively.
Please refer to the class documentation for more detailed explanation.
discardReadBytes in interface HornetQBufferpublic HornetQBuffer duplicate()
HornetQBufferbuf.slice(0, buf.capacity()).
This method does not modify readerIndex or writerIndex of
this buffer.duplicate in interface HornetQBufferpublic byte getByte(int index)
HornetQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.getByte in interface HornetQBufferpublic void getBytes(int index,
byte[] dst,
int dstIndex,
int length)
HornetQBufferindex.
This method does not modify readerIndex or writerIndex
of this buffer.getBytes in interface HornetQBufferdstIndex - the first index of the destinationlength - the number of bytes to transferpublic void getBytes(int index,
byte[] dst)
HornetQBufferindex.
This method does not modify readerIndex or writerIndex of
this buffergetBytes in interface HornetQBufferpublic void getBytes(int index,
ByteBuffer dst)
HornetQBufferindex until the destination's position
reaches its limit.
This method does not modify readerIndex or writerIndex of
this buffer while the destination's position will be increased.getBytes in interface HornetQBufferpublic void getBytes(int index,
HornetQBuffer dst,
int dstIndex,
int length)
HornetQBufferindex.
This method does not modify readerIndex or writerIndex
of both the source (i.e. this) and the destination.getBytes in interface HornetQBufferdstIndex - the first index of the destinationlength - the number of bytes to transferpublic void getBytes(int index,
HornetQBuffer dst,
int length)
HornetQBufferindex. This method is basically same
with HornetQBuffer.getBytes(int, HornetQBuffer, int, int), except that this
method increases the writerIndex of the destination by the
number of the transferred bytes while
HornetQBuffer.getBytes(int, HornetQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).getBytes in interface HornetQBufferlength - the number of bytes to transferpublic void getBytes(int index,
HornetQBuffer dst)
HornetQBufferindex until the destination becomes
non-writable. This method is basically same with
HornetQBuffer.getBytes(int, HornetQBuffer, int, int), except that this
method increases the writerIndex of the destination by the
number of the transferred bytes while
HornetQBuffer.getBytes(int, HornetQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).getBytes in interface HornetQBufferpublic char getChar(int index)
HornetQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getChar in interface HornetQBufferpublic double getDouble(int index)
HornetQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getDouble in interface HornetQBufferpublic float getFloat(int index)
HornetQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getFloat in interface HornetQBufferpublic int getInt(int index)
HornetQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getInt in interface HornetQBufferpublic long getLong(int index)
HornetQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getLong in interface HornetQBufferpublic short getShort(int index)
HornetQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getShort in interface HornetQBufferpublic short getUnsignedByte(int index)
HornetQBufferindex in this
buffer. This method does not modify readerIndex or
writerIndex of this buffer.getUnsignedByte in interface HornetQBufferpublic long getUnsignedInt(int index)
HornetQBufferindex
in this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getUnsignedInt in interface HornetQBufferpublic int getUnsignedShort(int index)
HornetQBufferindex in this buffer. This method does not modify
readerIndex or writerIndex of this buffer.getUnsignedShort in interface HornetQBufferpublic void markReaderIndex()
HornetQBufferreaderIndex in this buffer. You can
reposition the current readerIndex to the marked
readerIndex by calling HornetQBuffer.resetReaderIndex().
The initial value of the marked readerIndex is 0.markReaderIndex in interface HornetQBufferpublic void markWriterIndex()
HornetQBufferwriterIndex in this buffer. You can
reposition the current writerIndex to the marked
writerIndex by calling HornetQBuffer.resetWriterIndex().
The initial value of the marked writerIndex is 0.markWriterIndex in interface HornetQBufferpublic boolean readable()
HornetQBuffertrue
if and only if (this.writerIndex - this.readerIndex) is greater
than 0.readable in interface HornetQBufferpublic int readableBytes()
HornetQBuffer(this.writerIndex - this.readerIndex).readableBytes in interface HornetQBufferpublic byte readByte()
HornetQBufferreaderIndex and increases
the readerIndex by 1 in this buffer.readByte in interface HornetQBufferpublic void readBytes(byte[] dst,
int dstIndex,
int length)
HornetQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= length).readBytes in interface HornetQBufferdstIndex - the first index of the destinationlength - the number of bytes to transferpublic void readBytes(byte[] dst)
HornetQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= dst.length).readBytes in interface HornetQBufferpublic void readBytes(ByteBuffer dst)
HornetQBufferreaderIndex until the destination's position
reaches its limit, and increases the readerIndex by the
number of the transferred bytes.readBytes in interface HornetQBufferpublic void readBytes(HornetQBuffer dst, int dstIndex, int length)
HornetQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= length).readBytes in interface HornetQBufferdstIndex - the first index of the destinationlength - the number of bytes to transferpublic void readBytes(HornetQBuffer dst, int length)
HornetQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= length). This method
is basically same with HornetQBuffer.readBytes(HornetQBuffer, int, int),
except that this method increases the writerIndex of the
destination by the number of the transferred bytes (= length)
while HornetQBuffer.readBytes(HornetQBuffer, int, int) does not.readBytes in interface HornetQBufferpublic void readBytes(HornetQBuffer dst)
HornetQBufferreaderIndex until the destination becomes
non-writable, and increases the readerIndex by the number of the
transferred bytes. This method is basically same with
HornetQBuffer.readBytes(HornetQBuffer, int, int), except that this method
increases the writerIndex of the destination by the number of
the transferred bytes while HornetQBuffer.readBytes(HornetQBuffer, int, int)
does not.readBytes in interface HornetQBufferpublic HornetQBuffer readBytes(int length)
HornetQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= length).
The returned buffer's readerIndex and writerIndex are
0 and length respectively.readBytes in interface HornetQBufferlength - the number of bytes to transferpublic char readChar()
HornetQBufferreaderIndex
and increases the readerIndex by 2 in this buffer.readChar in interface HornetQBufferpublic double readDouble()
HornetQBufferreaderIndex
and increases the readerIndex by 8 in this buffer.readDouble in interface HornetQBufferpublic int readerIndex()
HornetQBufferreaderIndex of this buffer.readerIndex in interface HornetQBufferpublic void readerIndex(int readerIndex)
HornetQBufferreaderIndex of this buffer.readerIndex in interface HornetQBufferpublic float readFloat()
HornetQBufferreaderIndex
and increases the readerIndex by 4 in this buffer.readFloat in interface HornetQBufferpublic int readInt()
HornetQBufferreaderIndex
and increases the readerIndex by 4 in this buffer.readInt in interface HornetQBufferpublic long readLong()
HornetQBufferreaderIndex
and increases the readerIndex by 8 in this buffer.readLong in interface HornetQBufferpublic short readShort()
HornetQBufferreaderIndex
and increases the readerIndex by 2 in this buffer.readShort in interface HornetQBufferpublic HornetQBuffer readSlice(int length)
HornetQBufferreaderIndex and increases the readerIndex by the size
of the new slice (= length).readSlice in interface HornetQBufferlength - the size of the new slicepublic short readUnsignedByte()
HornetQBufferreaderIndex and increases
the readerIndex by 1 in this buffer.readUnsignedByte in interface HornetQBufferpublic long readUnsignedInt()
HornetQBufferreaderIndex
and increases the readerIndex by 4 in this buffer.readUnsignedInt in interface HornetQBufferpublic int readUnsignedShort()
HornetQBufferreaderIndex
and increases the readerIndex by 2 in this buffer.readUnsignedShort in interface HornetQBufferpublic void resetReaderIndex()
HornetQBufferreaderIndex to the marked
readerIndex in this buffer.resetReaderIndex in interface HornetQBufferpublic void resetWriterIndex()
HornetQBufferwriterIndex to the marked
writerIndex in this buffer.resetWriterIndex in interface HornetQBufferpublic void setByte(int index,
byte value)
HornetQBufferindex in this
buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setByte in interface HornetQBufferpublic void setBytes(int index,
byte[] src,
int srcIndex,
int length)
HornetQBufferindex.
This method does not modify readerIndex or writerIndex of
this buffer.setBytes in interface HornetQBufferpublic void setBytes(int index,
byte[] src)
HornetQBufferindex.
This method does not modify readerIndex or writerIndex of
this buffer.setBytes in interface HornetQBufferpublic void setBytes(int index,
ByteBuffer src)
HornetQBufferindex until the source buffer's position
reaches its limit.
This method does not modify readerIndex or writerIndex of
this buffer.setBytes in interface HornetQBufferpublic void setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length)
HornetQBufferindex.
This method does not modify readerIndex or writerIndex
of both the source (i.e. this) and the destination.setBytes in interface HornetQBuffersrcIndex - the first index of the sourcelength - the number of bytes to transferpublic void setBytes(int index,
HornetQBuffer src,
int length)
HornetQBufferindex. This method is basically same
with HornetQBuffer.setBytes(int, HornetQBuffer, int, int), except that this
method increases the readerIndex of the source buffer by
the number of the transferred bytes while
HornetQBuffer.getBytes(int, HornetQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).setBytes in interface HornetQBufferlength - the number of bytes to transferpublic void setBytes(int index,
HornetQBuffer src)
HornetQBufferindex until the destination becomes
unreadable. This method is basically same with
HornetQBuffer.setBytes(int, HornetQBuffer, int, int), except that this
method increases the readerIndex of the source buffer by
the number of the transferred bytes while
HornetQBuffer.getBytes(int, HornetQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).setBytes in interface HornetQBufferpublic void setChar(int index,
char value)
HornetQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setChar in interface HornetQBufferpublic void setDouble(int index,
double value)
HornetQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setDouble in interface HornetQBufferpublic void setFloat(int index,
float value)
HornetQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setFloat in interface HornetQBufferpublic void setIndex(int readerIndex,
int writerIndex)
HornetQBufferreaderIndex and writerIndex of this buffer
in one shot. This method is useful when you have to worry about the
invocation order of HornetQBuffer.readerIndex(int) and HornetQBuffer.writerIndex(int)
methods. For example, the following code will fail:
// Create a buffer whose readerIndex, writerIndex and capacity are // 0, 0 and 8 respectively. ChannelBuffer buf = ChannelBuffers.buffer(8); // IndexOutOfBoundsException is thrown because the specified // readerIndex (2) cannot be greater than the current writerIndex (0). buf.readerIndex(2); buf.writerIndex(4);The following code will also fail:
// Create a buffer whose readerIndex, writerIndex and capacity are // 0, 8 and 8 respectively. ChannelBuffer buf = ChannelBuffers.wrappedBuffer(new byte[8]); // readerIndex becomes 8. buf.readLong(); // IndexOutOfBoundsException is thrown because the specified // writerIndex (4) cannot be less than the current readerIndex (8). buf.writerIndex(4); buf.readerIndex(2);By contrast,
HornetQBuffer.setIndex(int, int) guarantees that it never
throws an IndexOutOfBoundsException as long as the specified
indexes meet basic constraints, regardless what the current index
values of the buffer are:
// No matter what the current state of the buffer is, the following // call always succeeds as long as the capacity of the buffer is not // less than 4. buf.setIndex(2, 4);
setIndex in interface HornetQBufferpublic void setInt(int index,
int value)
HornetQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setInt in interface HornetQBufferpublic void setLong(int index,
long value)
HornetQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setLong in interface HornetQBufferpublic void setShort(int index,
short value)
HornetQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setShort in interface HornetQBufferpublic void skipBytes(int length)
HornetQBufferreaderIndex by the specified
length in this buffer.skipBytes in interface HornetQBufferpublic HornetQBuffer slice()
HornetQBufferbuf.slice(buf.readerIndex(), buf.readableBytes()).
This method does not modify readerIndex or writerIndex of
this buffer.slice in interface HornetQBufferpublic HornetQBuffer slice(int index, int length)
HornetQBufferreaderIndex or writerIndex of
this buffer.slice in interface HornetQBufferpublic ByteBuffer toByteBuffer()
HornetQBufferbuf.toByteBuffer(buf.readerIndex(), buf.readableBytes()).
This method does not modify readerIndex or writerIndex of
this buffer.toByteBuffer in interface HornetQBufferpublic ByteBuffer toByteBuffer(int index, int length)
HornetQBufferreaderIndex or writerIndex of
this buffer.toByteBuffer in interface HornetQBufferpublic boolean writable()
HornetQBuffertrue
if and only if (this.capacity - this.writerIndex) is greater
than 0.writable in interface HornetQBufferpublic int writableBytes()
HornetQBuffer(this.capacity - this.writerIndex).writableBytes in interface HornetQBufferpublic void writeByte(byte value)
HornetQBufferwriterIndex
and increases the writerIndex by 1 in this buffer.writeByte in interface HornetQBufferpublic void writeBytes(byte[] src,
int srcIndex,
int length)
HornetQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= length).writeBytes in interface HornetQBuffersrcIndex - the first index of the sourcelength - the number of bytes to transferpublic void writeBytes(byte[] src)
HornetQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= src.length).writeBytes in interface HornetQBufferpublic void writeBytes(ByteBuffer src)
HornetQBufferwriterIndex until the source buffer's position
reaches its limit, and increases the writerIndex by the
number of the transferred bytes.writeBytes in interface HornetQBufferpublic void writeBytes(HornetQBuffer src, int srcIndex, int length)
HornetQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= length).writeBytes in interface HornetQBuffersrcIndex - the first index of the sourcelength - the number of bytes to transferpublic void writeBytes(HornetQBuffer src, int length)
HornetQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= length). This method
is basically same with HornetQBuffer.writeBytes(HornetQBuffer, int, int),
except that this method increases the readerIndex of the source
buffer by the number of the transferred bytes (= length) while
HornetQBuffer.writeBytes(HornetQBuffer, int, int) does not.writeBytes in interface HornetQBufferlength - the number of bytes to transferpublic void writeChar(char chr)
HornetQBufferwriterIndex
and increases the writerIndex by 2 in this buffer.writeChar in interface HornetQBufferpublic void writeDouble(double value)
HornetQBufferwriterIndex
and increases the writerIndex by 8 in this buffer.writeDouble in interface HornetQBufferpublic void writeFloat(float value)
HornetQBufferwriterIndex
and increases the writerIndex by 4 in this buffer.writeFloat in interface HornetQBufferpublic void writeInt(int value)
HornetQBufferwriterIndex
and increases the writerIndex by 4 in this buffer.writeInt in interface HornetQBufferpublic void writeLong(long value)
HornetQBufferwriterIndex and increases the writerIndex by 8
in this buffer.writeLong in interface HornetQBufferpublic int writerIndex()
HornetQBufferwriterIndex of this buffer.writerIndex in interface HornetQBufferpublic void writerIndex(int writerIndex)
HornetQBufferwriterIndex of this buffer.writerIndex in interface HornetQBufferpublic void writeShort(short value)
HornetQBufferwriterIndex and increases the writerIndex by 2
in this buffer.writeShort in interface HornetQBufferCopyright © 2012 JBoss by Red Hat. All Rights Reserved.