public interface ActiveMQBuffer extends DataInput
Instances of it can be obtained from ActiveMQBuffers
factory.
Much of it derived from Netty ChannelBuffer by Trustin Lee
ActiveMQBuffers
Modifier and Type | Method and Description |
---|---|
io.netty.buffer.ByteBuf |
byteBuf()
Returns the underlying Netty's ByteBuf
|
int |
capacity()
Returns the number of bytes this buffer can contain.
|
void |
clear()
Sets the
readerIndex and writerIndex of this buffer to
0 . |
ActiveMQBuffer |
copy()
Returns a copy of this buffer's readable bytes.
|
ActiveMQBuffer |
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 . |
ActiveMQBuffer |
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,
ActiveMQBuffer 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,
ActiveMQBuffer dst,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
void |
getBytes(int index,
ActiveMQBuffer dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
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. |
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() |
int |
readableBytes() |
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(ActiveMQBuffer 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(ActiveMQBuffer 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(ActiveMQBuffer 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(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. |
ActiveMQBuffer |
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() |
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 |
ActiveMQBuffer |
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 |
int |
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 |
release()
Release any underlying resources held by this buffer
|
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,
ActiveMQBuffer 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,
ActiveMQBuffer src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
void |
setBytes(int index,
ActiveMQBuffer src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
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 |
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. |
int |
skipBytes(int length)
Increases the current
readerIndex by the specified
length in this buffer. |
ActiveMQBuffer |
slice()
Returns a slice of this buffer's readable bytes.
|
ActiveMQBuffer |
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() |
int |
writableBytes() |
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(ActiveMQBuffer 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(ActiveMQBuffer 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 |
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(io.netty.buffer.ByteBuf src,
int srcIndex,
int length)
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 |
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() |
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 |
io.netty.buffer.ByteBuf byteBuf()
int capacity()
int readerIndex()
readerIndex
of this buffer.void readerIndex(int readerIndex)
readerIndex
of this buffer.readerIndex
- The reader's index The reader infexIndexOutOfBoundsException
- if the specified readerIndex
is
less than 0
or
greater than this.writerIndex
int writerIndex()
writerIndex
of this buffer.void writerIndex(int writerIndex)
writerIndex
of this buffer.writerIndex
- The writer's indexIndexOutOfBoundsException
- if the specified writerIndex
is
less than this.readerIndex
or
greater than this.capacity
void setIndex(int readerIndex, int writerIndex)
readerIndex
and writerIndex
of this buffer
in one shot. This method is useful when you have to worry about the
invocation order of readerIndex(int)
and 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,
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);
readerIndex
- The reader's indexwriterIndex
- The writer's indexIndexOutOfBoundsException
- if the specified readerIndex
is less than 0,
if the specified writerIndex
is less than the specified
readerIndex
or if the specified writerIndex
is
greater than this.capacity
int readableBytes()
(this.writerIndex - this.readerIndex)
.int writableBytes()
(this.capacity - this.writerIndex)
.boolean readable()
true
if and only if (this.writerIndex - this.readerIndex)
is greater than 0
.boolean writable()
true
if and only if (this.capacity - this.writerIndex)
is greater than 0
.void clear()
readerIndex
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.
void markReaderIndex()
readerIndex
in this buffer. You can
reposition the current readerIndex
to the marked
readerIndex
by calling resetReaderIndex()
.
The initial value of the marked readerIndex
is 0
.void resetReaderIndex()
readerIndex
to the marked
readerIndex
in this buffer.IndexOutOfBoundsException
- if the current writerIndex
is less than the marked
readerIndex
void markWriterIndex()
writerIndex
in this buffer. You can
reposition the current writerIndex
to the marked
writerIndex
by calling resetWriterIndex()
.
The initial value of the marked writerIndex
is 0
.void resetWriterIndex()
writerIndex
to the marked
writerIndex
in this buffer.IndexOutOfBoundsException
- if the current readerIndex
is greater than the marked
writerIndex
void discardReadBytes()
readerIndex
.
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.
byte getByte(int index)
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 1
is greater than this.capacity
short getUnsignedByte(int index)
index
in this
buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- Index into the bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 1
is greater than this.capacity
short getShort(int index)
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- Index into the bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 2
is greater than this.capacity
int getUnsignedShort(int index)
index
in this buffer. This method does not modify
readerIndex
or writerIndex
of this buffer.index
- Index into the bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 2
is greater than this.capacity
int getInt(int index)
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- Index into the bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 4
is greater than this.capacity
long getUnsignedInt(int index)
index
in this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- The index into this bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 4
is greater than this.capacity
long getLong(int index)
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- Index into the bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 8
is greater than this.capacity
void getBytes(int index, ActiveMQBuffer dst)
index
until the destination becomes
non-writable. This method is basically same with
getBytes(int, ActiveMQBuffer, int, int)
, except that this
method increases the writerIndex
of the destination by the
number of the transferred bytes while
getBytes(int, ActiveMQBuffer, int, int)
does not.
This method does not modify readerIndex
or writerIndex
of
the source buffer (i.e. this
).index
- Index into the bufferdst
- The destination bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
if index + dst.writableBytes
is greater than
this.capacity
void getBytes(int index, ActiveMQBuffer dst, int length)
index
. This method is basically same
with getBytes(int, ActiveMQBuffer, int, int)
, except that this
method increases the writerIndex
of the destination by the
number of the transferred bytes while
getBytes(int, ActiveMQBuffer, int, int)
does not.
This method does not modify readerIndex
or writerIndex
of
the source buffer (i.e. this
).length
- the number of bytes to transferindex
- Index into the bufferdst
- The destination bufferIndexOutOfBoundsException
- if the specified index
is less than 0
,
if index + length
is greater than
this.capacity
, or
if length
is greater than dst.writableBytes
void getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)
index
.
This method does not modify readerIndex
or writerIndex
of both the source (i.e. this
) and the destination.dst
- The destination bufferIndex the first index of the destinationlength
- The number of bytes to transferindex
- Index into the bufferdstIndex
- The index into the destination bufferThe destination bufferIndexOutOfBoundsException
- if the specified index
is less than 0
,
if the specified dstIndex
is less than 0
,
if index + length
is greater than
this.capacity
, or
if dstIndex + length
is greater than
dst.capacity
void getBytes(int index, byte[] dst)
index
.
This method does not modify readerIndex
or writerIndex
of
this bufferindex
- Index into the bufferdst
- The destination bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
if index + dst.length
is greater than
this.capacity
void getBytes(int index, byte[] dst, int dstIndex, int length)
index
.
This method does not modify readerIndex
or writerIndex
of this buffer.dstIndex
- The first index of the destinationlength
- The number of bytes to transferindex
- Index into the bufferdst
- The destination bufferIndexOutOfBoundsException
- if the specified index
is less than 0
,
if the specified dstIndex
is less than 0
,
if index + length
is greater than
this.capacity
, or
if dstIndex + length
is greater than
dst.length
void getBytes(int index, ByteBuffer dst)
index
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.index
- Index into the bufferdst
- The destination bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
if index + dst.remaining()
is greater than
this.capacity
char getChar(int index)
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- Index into the bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 2
is greater than this.capacity
float getFloat(int index)
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- Index into the bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 4
is greater than this.capacity
double getDouble(int index)
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.index
- Index into the bufferindex
IndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 8
is greater than this.capacity
void setByte(int index, byte value)
index
in this
buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffervalue
- The specified byteIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 1
is greater than this.capacity
void setShort(int index, short value)
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffervalue
- The specified 16-bit short integerIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 2
is greater than this.capacity
void setInt(int index, int value)
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffervalue
- The specified 32-bit integerIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 4
is greater than this.capacity
void setLong(int index, long value)
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffervalue
- The specified 64-bit long integerIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 8
is greater than this.capacity
void setBytes(int index, ActiveMQBuffer src)
index
until the destination becomes
unreadable. This method is basically same with
setBytes(int, ActiveMQBuffer, int, int)
, except that this
method increases the readerIndex
of the source buffer by
the number of the transferred bytes while
getBytes(int, ActiveMQBuffer, int, int)
does not.
This method does not modify readerIndex
or writerIndex
of
the source buffer (i.e. this
).index
- Index into the buffersrc
- The source bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
if index + src.readableBytes
is greater than
this.capacity
void setBytes(int index, ActiveMQBuffer src, int length)
index
. This method is basically same
with setBytes(int, ActiveMQBuffer, int, int)
, except that this
method increases the readerIndex
of the source buffer by
the number of the transferred bytes while
getBytes(int, ActiveMQBuffer, int, int)
does not.
This method does not modify readerIndex
or writerIndex
of
the source buffer (i.e. this
).length
- the number of bytes to transferindex
- Index into the buffersrc
- The source bufferIndexOutOfBoundsException
- if the specified index
is less than 0
,
if index + length
is greater than
this.capacity
, or
if length
is greater than src.readableBytes
void setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
index
.
This method does not modify readerIndex
or writerIndex
of both the source (i.e. this
) and the destination.src
- The source bufferIndex the first index of the sourcelength
- The number of bytes to transferindex
- Index into the buffersrcIndex
- The source buffer indexIndexOutOfBoundsException
- if the specified index
is less than 0
,
if the specified srcIndex
is less than 0
,
if index + length
is greater than
this.capacity
, or
if srcIndex + length
is greater than
src.capacity
void setBytes(int index, byte[] src)
index
.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffersrc
- The source bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
if index + src.length
is greater than
this.capacity
void setBytes(int index, byte[] src, int srcIndex, int length)
index
.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffersrc
- The source buffersrcIndex
- The source buffer indexlength
- The number of bytes to transferIndexOutOfBoundsException
- if the specified index
is less than 0
,
if the specified srcIndex
is less than 0
,
if index + length
is greater than
this.capacity
, or
if srcIndex + length
is greater than src.length
void setBytes(int index, ByteBuffer src)
index
until the source buffer's position
reaches its limit.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffersrc
- The source bufferIndexOutOfBoundsException
- if the specified index
is less than 0
or
if index + src.remaining()
is greater than
this.capacity
void setChar(int index, char value)
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffervalue
- The specified charIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 2
is greater than this.capacity
void setFloat(int index, float value)
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffervalue
- The specified floatIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 4
is greater than this.capacity
void setDouble(int index, double value)
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.index
- Index into the buffervalue
- The specified doubleIndexOutOfBoundsException
- if the specified index
is less than 0
or
index + 8
is greater than this.capacity
byte readByte()
readerIndex
and increases
the readerIndex
by 1
in this buffer.readByte
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 1
int readUnsignedByte()
readerIndex
and increases
the readerIndex
by 1
in this buffer.readUnsignedByte
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 1
short readShort()
readerIndex
and increases the readerIndex
by 2
in this buffer.readShort
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 2
int readUnsignedShort()
readerIndex
and increases the readerIndex
by 2
in this buffer.readUnsignedShort
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 2
int readInt()
readerIndex
and increases the readerIndex
by 4
in this buffer.readInt
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 4
long readUnsignedInt()
readerIndex
and increases the readerIndex
by 4
in this buffer.readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 4
long readLong()
readerIndex
and increases the readerIndex
by 8
in this buffer.readLong
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 8
char readChar()
readerIndex
and increases the readerIndex
by 2
in this buffer.readChar
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 2
float readFloat()
readerIndex
and increases the readerIndex
by 4
in this buffer.readFloat
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 4
double readDouble()
readerIndex
and increases the readerIndex
by 8
in this buffer.readDouble
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 8
boolean readBoolean()
readerIndex
and increases the readerIndex
by 1
in this buffer.readBoolean
in interface DataInput
readerIndex
IndexOutOfBoundsException
- if this.readableBytes
is less than 1
SimpleString readNullableSimpleString()
null
) at the current readerIndex
null
) at the current readerIndex
String readNullableString()
null
) at the current readerIndex
null
) at the current readerIndex
SimpleString readSimpleString()
readerIndex
readerIndex
String readString()
readerIndex
readerIndex
String readUTF()
readerIndex
ActiveMQBuffer readBytes(int length)
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).
The returned buffer's readerIndex
and writerIndex
are
0
and length
respectively.length
- the number of bytes to transferIndexOutOfBoundsException
- if length
is greater than this.readableBytes
ActiveMQBuffer readSlice(int length)
readerIndex
and increases the readerIndex
by the size
of the new slice (= length
).length
- the size of the new sliceIndexOutOfBoundsException
- if length
is greater than this.readableBytes
void readBytes(ActiveMQBuffer dst)
readerIndex
until the destination becomes
non-writable, and increases the readerIndex
by the number of the
transferred bytes. This method is basically same with
readBytes(ActiveMQBuffer, int, int)
, except that this method
increases the writerIndex
of the destination by the number of
the transferred bytes while readBytes(ActiveMQBuffer, int, int)
does not.dst
- The destination bufferIndexOutOfBoundsException
- if dst.writableBytes
is greater than
this.readableBytes
void readBytes(ActiveMQBuffer dst, int length)
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
). This method
is basically same with readBytes(ActiveMQBuffer, int, int)
,
except that this method increases the writerIndex
of the
destination by the number of the transferred bytes (= length
)
while readBytes(ActiveMQBuffer, int, int)
does not.dst
- The destination bufferlength
- The number of bytes to transferIndexOutOfBoundsException
- if length
is greater than this.readableBytes
or
if length
is greater than dst.writableBytes
void readBytes(ActiveMQBuffer dst, int dstIndex, int length)
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).dstIndex
- The destination buffer indexlength
- the number of bytes to transferdst
- The destination bufferIndexOutOfBoundsException
- if the specified dstIndex
is less than 0
,
if length
is greater than this.readableBytes
, or
if dstIndex + length
is greater than
dst.capacity
void readBytes(byte[] dst)
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= dst.length
).dst
- The destination bufferIndexOutOfBoundsException
- if dst.length
is greater than this.readableBytes
void readBytes(byte[] dst, int dstIndex, int length)
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).dstIndex
- The destination bufferIndexlength
- the number of bytes to transferdst
- The destination bufferIndexOutOfBoundsException
- if the specified dstIndex
is less than 0
,
if length
is greater than this.readableBytes
, or
if dstIndex + length
is greater than dst.length
void readBytes(ByteBuffer dst)
readerIndex
until the destination's position
reaches its limit, and increases the readerIndex
by the
number of the transferred bytes.dst
- The destination bufferIndexOutOfBoundsException
- if dst.remaining()
is greater than
this.readableBytes
int skipBytes(int length)
readerIndex
by the specified
length
in this buffer.skipBytes
in interface DataInput
length
- The number of bytes to skipIndexOutOfBoundsException
- if length
is greater than this.readableBytes
void writeByte(byte value)
writerIndex
and increases the writerIndex
by 1
in this buffer.value
- The specified byteIndexOutOfBoundsException
- if this.writableBytes
is less than 1
void writeShort(short value)
writerIndex
and increases the writerIndex
by 2
in this buffer.value
- The specified 16-bit short integerIndexOutOfBoundsException
- if this.writableBytes
is less than 2
void writeInt(int value)
writerIndex
and increases the writerIndex
by 4
in this buffer.value
- The specified 32-bit integerIndexOutOfBoundsException
- if this.writableBytes
is less than 4
void writeLong(long value)
writerIndex
and increases the writerIndex
by 8
in this buffer.value
- The specified 64-bit long integerIndexOutOfBoundsException
- if this.writableBytes
is less than 8
void writeChar(char chr)
writerIndex
and increases the writerIndex
by 2
in this buffer.chr
- The specified charIndexOutOfBoundsException
- if this.writableBytes
is less than 2
void writeFloat(float value)
writerIndex
and increases the writerIndex
by 4
in this buffer.value
- The specified floatIndexOutOfBoundsException
- if this.writableBytes
is less than 4
void writeDouble(double value)
writerIndex
and increases the writerIndex
by 8
in this buffer.value
- The specified doubleIndexOutOfBoundsException
- if this.writableBytes
is less than 8
void writeBoolean(boolean val)
writerIndex
val
- The specified booleanvoid writeNullableSimpleString(SimpleString val)
null
) at the current writerIndex
val
- The specified SimpleStringvoid writeNullableString(String val)
null
) at the current writerIndex
val
- The specified Stringvoid writeSimpleString(SimpleString val)
writerIndex
val
- The specified non-null SimpleStringvoid writeString(String val)
writerIndex
val
- The specified non-null Stringvoid writeUTF(String utf)
writerIndex
utf
- The specified UTF-8 Stringvoid writeBytes(ActiveMQBuffer src, int length)
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
). This method
is basically same with writeBytes(ActiveMQBuffer, int, int)
,
except that this method increases the readerIndex
of the source
buffer by the number of the transferred bytes (= length
) while
writeBytes(ActiveMQBuffer, int, int)
does not.length
- the number of bytes to transfersrc
- The source bufferIndexOutOfBoundsException
- if length
is greater than this.writableBytes
or
if length
is greater then src.readableBytes
void writeBytes(ActiveMQBuffer src, int srcIndex, int length)
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
).srcIndex
- the first index of the sourcelength
- the number of bytes to transfersrc
- The source bufferIndexOutOfBoundsException
- if the specified srcIndex
is less than 0
,
if srcIndex + length
is greater than
src.capacity
, or
if length
is greater than this.writableBytes
void writeBytes(byte[] src)
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= src.length
).src
- The source bufferIndexOutOfBoundsException
- if src.length
is greater than this.writableBytes
void writeBytes(byte[] src, int srcIndex, int length)
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
).srcIndex
- the first index of the sourcelength
- the number of bytes to transfersrc
- The source bufferIndexOutOfBoundsException
- if the specified srcIndex
is less than 0
,
if srcIndex + length
is greater than
src.length
, or
if length
is greater than this.writableBytes
void writeBytes(ByteBuffer src)
writerIndex
until the source buffer's position
reaches its limit, and increases the writerIndex
by the
number of the transferred bytes.src
- The source bufferIndexOutOfBoundsException
- if src.remaining()
is greater than
this.writableBytes
void writeBytes(io.netty.buffer.ByteBuf src, int srcIndex, int length)
writerIndex
until the source buffer's position
reaches its limit, and increases the writerIndex
by the
number of the transferred bytes.src
- The source bufferIndexOutOfBoundsException
- if src.remaining()
is greater than
this.writableBytes
ActiveMQBuffer copy()
buf.copy(buf.readerIndex(), buf.readableBytes())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.ActiveMQBuffer copy(int index, int length)
readerIndex
or writerIndex
of
this buffer.index
- Index into the bufferlength
- The number of bytes to copyActiveMQBuffer slice()
buf.slice(buf.readerIndex(), buf.readableBytes())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.ActiveMQBuffer slice(int index, int length)
readerIndex
or writerIndex
of
this buffer.index
- Index into the bufferlength
- The number of bytesActiveMQBuffer duplicate()
buf.slice(0, buf.capacity())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.ByteBuffer toByteBuffer()
buf.toByteBuffer(buf.readerIndex(), buf.readableBytes())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.ByteBuffer toByteBuffer(int index, int length)
readerIndex
or writerIndex
of
this buffer.index
- Index into the bufferlength
- The number of bytesvoid release()
Copyright © 2017 JBoss by Red Hat. All rights reserved.