public class ChannelBufferWrapper extends Object implements ActiveMQBuffer
| Modifier and Type | Field and Description |
|---|---|
protected io.netty.buffer.ByteBuf |
buffer |
| Constructor and Description |
|---|
ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer) |
ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer,
boolean releasable) |
ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer,
boolean releasable,
boolean pooled) |
| 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. |
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. |
void |
readFully(byte[] b)
from
DataInput interface |
void |
readFully(byte[] b,
int off,
int len)
from
DataInput interface |
int |
readInt()
Gets a 32-bit integer at the current
readerIndex
and increases the readerIndex by 4 in this buffer. |
String |
readLine()
from
DataInput interface |
long |
readLong()
Gets a 64-bit integer at the current
readerIndex
and increases the readerIndex by 8 in this buffer. |
Boolean |
readNullableBoolean()
Gets a (potentially
null) boolean at the current readerIndex
and increases the readerIndex by 1 in this buffer. |
Integer |
readNullableInt()
Gets a (potentially
null) 32-bit integer at the current readerIndex
and increases the readerIndex by 4 in this buffer. |
Long |
readNullableLong()
Gets a (potentially
null) 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.
|
static io.netty.buffer.ByteBuf |
unwrap(io.netty.buffer.ByteBuf 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 |
writeNullableBoolean(Boolean val)
Sets the specified (potentially
null) Boolean at the current writerIndex |
void |
writeNullableInt(Integer value)
Sets the specified (potentially
null) 32-bit integer at the current writerIndex
and increases the writerIndex by 4 in this buffer. |
void |
writeNullableLong(Long value)
Sets the specified (potentially
null) 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 |
public ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer)
public ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer,
boolean releasable)
public ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer,
boolean releasable,
boolean pooled)
public static io.netty.buffer.ByteBuf unwrap(io.netty.buffer.ByteBuf buffer)
public boolean readBoolean()
ActiveMQBufferreaderIndex
and increases the readerIndex by 1 in this buffer.readBoolean in interface DataInputreadBoolean in interface ActiveMQBufferreaderIndexpublic Boolean readNullableBoolean()
ActiveMQBuffernull) boolean at the current readerIndex
and increases the readerIndex by 1 in this buffer.readNullableBoolean in interface ActiveMQBuffernull) boolean at the current readerIndexpublic SimpleString readNullableSimpleString()
ActiveMQBuffernull) at the current readerIndexreadNullableSimpleString in interface ActiveMQBuffernull) at the current readerIndexpublic String readNullableString()
ActiveMQBuffernull) at the current readerIndexreadNullableString in interface ActiveMQBuffernull) at the current readerIndexpublic SimpleString readSimpleString()
ActiveMQBufferreaderIndexreadSimpleString in interface ActiveMQBufferreaderIndexpublic String readString()
ActiveMQBufferreaderIndexreadString in interface ActiveMQBufferreaderIndexpublic void writeNullableString(String val)
ActiveMQBuffernull) at the current writerIndexwriteNullableString in interface ActiveMQBufferval - The specified Stringpublic void writeUTF(String utf)
ActiveMQBufferwriterIndexwriteUTF in interface ActiveMQBufferutf - The specified UTF-8 Stringpublic String readUTF()
ActiveMQBufferreaderIndexreadUTF in interface DataInputreadUTF in interface ActiveMQBufferreaderIndexpublic void writeBoolean(boolean val)
ActiveMQBufferwriterIndexwriteBoolean in interface ActiveMQBufferval - The specified booleanpublic void writeNullableBoolean(Boolean val)
ActiveMQBuffernull) Boolean at the current writerIndexwriteNullableBoolean in interface ActiveMQBufferval - The specified booleanpublic void writeNullableSimpleString(SimpleString val)
ActiveMQBuffernull) at the current writerIndexwriteNullableSimpleString in interface ActiveMQBufferval - The specified SimpleStringpublic void writeSimpleString(SimpleString val)
ActiveMQBufferwriterIndexwriteSimpleString in interface ActiveMQBufferval - The specified non-null SimpleStringpublic void writeString(String val)
ActiveMQBufferwriterIndexwriteString in interface ActiveMQBufferval - The specified non-null Stringpublic int capacity()
ActiveMQBuffercapacity in interface ActiveMQBufferpublic io.netty.buffer.ByteBuf byteBuf()
ActiveMQBufferbyteBuf in interface ActiveMQBufferpublic void clear()
ActiveMQBufferreaderIndex 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 ActiveMQBufferpublic ActiveMQBuffer copy()
ActiveMQBufferbuf.copy(buf.readerIndex(), buf.readableBytes()).
This method does not modify readerIndex or writerIndex of
this buffer.copy in interface ActiveMQBufferpublic ActiveMQBuffer copy(int index, int length)
ActiveMQBufferreaderIndex or writerIndex of
this buffer.copy in interface ActiveMQBufferindex - Index into the bufferlength - The number of bytes to copypublic void discardReadBytes()
ActiveMQBufferreaderIndex.
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 ActiveMQBufferpublic ActiveMQBuffer duplicate()
ActiveMQBufferbuf.slice(0, buf.capacity()).
This method does not modify readerIndex or writerIndex of
this buffer.duplicate in interface ActiveMQBufferpublic byte getByte(int index)
ActiveMQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.getByte in interface ActiveMQBufferindex - Index into the bufferpublic void getBytes(int index,
byte[] dst,
int dstIndex,
int length)
ActiveMQBufferindex.
This method does not modify readerIndex or writerIndex
of this buffer.getBytes in interface ActiveMQBufferindex - Index into the bufferdst - The destination bufferdstIndex - The first index of the destinationlength - The number of bytes to transferpublic void getBytes(int index,
byte[] dst)
ActiveMQBufferindex.
This method does not modify readerIndex or writerIndex of
this buffergetBytes in interface ActiveMQBufferindex - Index into the bufferdst - The destination bufferpublic void getBytes(int index,
ByteBuffer dst)
ActiveMQBufferindex 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 ActiveMQBufferindex - Index into the bufferdst - The destination bufferpublic void getBytes(int index,
ActiveMQBuffer dst,
int dstIndex,
int length)
ActiveMQBufferindex.
This method does not modify readerIndex or writerIndex
of both the source (i.e. this) and the destination.getBytes in interface ActiveMQBufferindex - Index into the bufferdst - The destination bufferIndex the first index of the destinationdstIndex - The index into the destination bufferThe destination bufferlength - The number of bytes to transferpublic void getBytes(int index,
ActiveMQBuffer dst,
int length)
ActiveMQBufferindex. This method is basically same
with ActiveMQBuffer.getBytes(int, ActiveMQBuffer, int, int), except that this
method increases the writerIndex of the destination by the
number of the transferred bytes while
ActiveMQBuffer.getBytes(int, ActiveMQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).getBytes in interface ActiveMQBufferindex - Index into the bufferdst - The destination bufferlength - the number of bytes to transferpublic void getBytes(int index,
ActiveMQBuffer dst)
ActiveMQBufferindex until the destination becomes
non-writable. This method is basically same with
ActiveMQBuffer.getBytes(int, ActiveMQBuffer, int, int), except that this
method increases the writerIndex of the destination by the
number of the transferred bytes while
ActiveMQBuffer.getBytes(int, ActiveMQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).getBytes in interface ActiveMQBufferindex - Index into the bufferdst - The destination bufferpublic char getChar(int index)
ActiveMQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getChar in interface ActiveMQBufferindex - Index into the bufferindexpublic double getDouble(int index)
ActiveMQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getDouble in interface ActiveMQBufferindex - Index into the bufferindexpublic float getFloat(int index)
ActiveMQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getFloat in interface ActiveMQBufferindex - Index into the bufferindexpublic int getInt(int index)
ActiveMQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getInt in interface ActiveMQBufferindex - Index into the bufferindexpublic long getLong(int index)
ActiveMQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getLong in interface ActiveMQBufferindex - Index into the bufferindexpublic short getShort(int index)
ActiveMQBufferindex in
this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getShort in interface ActiveMQBufferindex - Index into the bufferindexpublic short getUnsignedByte(int index)
ActiveMQBufferindex in this
buffer. This method does not modify readerIndex or
writerIndex of this buffer.getUnsignedByte in interface ActiveMQBufferindex - Index into the bufferindexpublic long getUnsignedInt(int index)
ActiveMQBufferindex
in this buffer. This method does not modify readerIndex or
writerIndex of this buffer.getUnsignedInt in interface ActiveMQBufferindex - The index into this bufferindexpublic int getUnsignedShort(int index)
ActiveMQBufferindex in this buffer. This method does not modify
readerIndex or writerIndex of this buffer.getUnsignedShort in interface ActiveMQBufferindex - Index into the bufferpublic void markReaderIndex()
ActiveMQBufferreaderIndex in this buffer. You can
reposition the current readerIndex to the marked
readerIndex by calling ActiveMQBuffer.resetReaderIndex().
The initial value of the marked readerIndex is 0.markReaderIndex in interface ActiveMQBufferpublic void markWriterIndex()
ActiveMQBufferwriterIndex in this buffer. You can
reposition the current writerIndex to the marked
writerIndex by calling ActiveMQBuffer.resetWriterIndex().
The initial value of the marked writerIndex is 0.markWriterIndex in interface ActiveMQBufferpublic boolean readable()
readable in interface ActiveMQBuffertrue if and only if (this.writerIndex - this.readerIndex) is greater than 0.public int readableBytes()
readableBytes in interface ActiveMQBuffer(this.writerIndex - this.readerIndex).public byte readByte()
ActiveMQBufferreaderIndex and increases
the readerIndex by 1 in this buffer.readByte in interface DataInputreadByte in interface ActiveMQBufferreaderIndexpublic void readBytes(byte[] dst,
int dstIndex,
int length)
ActiveMQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= length).readBytes in interface ActiveMQBufferdst - The destination bufferdstIndex - The destination bufferIndexlength - the number of bytes to transferpublic void readBytes(byte[] dst)
ActiveMQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= dst.length).readBytes in interface ActiveMQBufferdst - The destination bufferpublic void readBytes(ByteBuffer dst)
ActiveMQBufferreaderIndex until the destination's position
reaches its limit, and increases the readerIndex by the
number of the transferred bytes.readBytes in interface ActiveMQBufferdst - The destination bufferpublic void readBytes(ActiveMQBuffer dst, int dstIndex, int length)
ActiveMQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= length).readBytes in interface ActiveMQBufferdst - The destination bufferdstIndex - The destination buffer indexlength - the number of bytes to transferpublic void readBytes(ActiveMQBuffer dst, int length)
ActiveMQBufferreaderIndex and increases the readerIndex
by the number of the transferred bytes (= length). This method
is basically same with ActiveMQBuffer.readBytes(ActiveMQBuffer, int, int),
except that this method increases the writerIndex of the
destination by the number of the transferred bytes (= length)
while ActiveMQBuffer.readBytes(ActiveMQBuffer, int, int) does not.readBytes in interface ActiveMQBufferdst - The destination bufferlength - The number of bytes to transferpublic void readBytes(ActiveMQBuffer dst)
ActiveMQBufferreaderIndex until the destination becomes
non-writable, and increases the readerIndex by the number of the
transferred bytes. This method is basically same with
ActiveMQBuffer.readBytes(ActiveMQBuffer, int, int), except that this method
increases the writerIndex of the destination by the number of
the transferred bytes while ActiveMQBuffer.readBytes(ActiveMQBuffer, int, int)
does not.readBytes in interface ActiveMQBufferdst - The destination bufferpublic char readChar()
ActiveMQBufferreaderIndex
and increases the readerIndex by 2 in this buffer.readChar in interface DataInputreadChar in interface ActiveMQBufferreaderIndexpublic double readDouble()
ActiveMQBufferreaderIndex
and increases the readerIndex by 8 in this buffer.readDouble in interface DataInputreadDouble in interface ActiveMQBufferreaderIndexpublic int readerIndex()
readerIndex in interface ActiveMQBufferreaderIndex of this buffer.public void readerIndex(int readerIndex)
ActiveMQBufferreaderIndex of this buffer.readerIndex in interface ActiveMQBufferreaderIndex - The reader's indexpublic float readFloat()
ActiveMQBufferreaderIndex
and increases the readerIndex by 4 in this buffer.readFloat in interface DataInputreadFloat in interface ActiveMQBufferreaderIndexpublic int readInt()
ActiveMQBufferreaderIndex
and increases the readerIndex by 4 in this buffer.readInt in interface DataInputreadInt in interface ActiveMQBufferreaderIndexpublic Integer readNullableInt()
ActiveMQBuffernull) 32-bit integer at the current readerIndex
and increases the readerIndex by 4 in this buffer.readNullableInt in interface ActiveMQBuffernull) 32-bit integer at the current readerIndexpublic long readLong()
ActiveMQBufferreaderIndex
and increases the readerIndex by 8 in this buffer.readLong in interface DataInputreadLong in interface ActiveMQBufferreaderIndexpublic Long readNullableLong()
ActiveMQBuffernull) 64-bit integer at the current readerIndex
and increases the readerIndex by 8 in this buffer.readNullableLong in interface ActiveMQBuffernull) 64-bit integer at the current readerIndexpublic short readShort()
ActiveMQBufferreaderIndex
and increases the readerIndex by 2 in this buffer.readShort in interface DataInputreadShort in interface ActiveMQBufferreaderIndexpublic ActiveMQBuffer readSlice(int length)
ActiveMQBufferreaderIndex and increases the readerIndex by the size
of the new slice (= length).readSlice in interface ActiveMQBufferlength - the size of the new slicepublic int readUnsignedByte()
ActiveMQBufferreaderIndex and increases
the readerIndex by 1 in this buffer.readUnsignedByte in interface DataInputreadUnsignedByte in interface ActiveMQBufferreaderIndexpublic long readUnsignedInt()
ActiveMQBufferreaderIndex
and increases the readerIndex by 4 in this buffer.readUnsignedInt in interface ActiveMQBufferreaderIndexpublic int readUnsignedShort()
ActiveMQBufferreaderIndex
and increases the readerIndex by 2 in this buffer.readUnsignedShort in interface DataInputreadUnsignedShort in interface ActiveMQBufferreaderIndexpublic void resetReaderIndex()
ActiveMQBufferreaderIndex to the marked
readerIndex in this buffer.resetReaderIndex in interface ActiveMQBufferpublic void resetWriterIndex()
ActiveMQBufferwriterIndex to the marked
writerIndex in this buffer.resetWriterIndex in interface ActiveMQBufferpublic void setByte(int index,
byte value)
ActiveMQBufferindex in this
buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setByte in interface ActiveMQBufferindex - Index into the buffervalue - The specified bytepublic void setBytes(int index,
byte[] src,
int srcIndex,
int length)
ActiveMQBufferindex.
This method does not modify readerIndex or writerIndex of
this buffer.setBytes in interface ActiveMQBufferindex - Index into the buffersrc - The source buffersrcIndex - The source buffer indexlength - The number of bytes to transferpublic void setBytes(int index,
byte[] src)
ActiveMQBufferindex.
This method does not modify readerIndex or writerIndex of
this buffer.setBytes in interface ActiveMQBufferindex - Index into the buffersrc - The source bufferpublic void setBytes(int index,
ByteBuffer src)
ActiveMQBufferindex until the source buffer's position
reaches its limit.
This method does not modify readerIndex or writerIndex of
this buffer.setBytes in interface ActiveMQBufferindex - Index into the buffersrc - The source bufferpublic void setBytes(int index,
ActiveMQBuffer src,
int srcIndex,
int length)
ActiveMQBufferindex.
This method does not modify readerIndex or writerIndex
of both the source (i.e. this) and the destination.setBytes in interface ActiveMQBufferindex - Index into the buffersrc - The source bufferIndex the first index of the sourcesrcIndex - The source buffer indexlength - The number of bytes to transferpublic void setBytes(int index,
ActiveMQBuffer src,
int length)
ActiveMQBufferindex. This method is basically same
with ActiveMQBuffer.setBytes(int, ActiveMQBuffer, int, int), except that this
method increases the readerIndex of the source buffer by
the number of the transferred bytes while
ActiveMQBuffer.getBytes(int, ActiveMQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).setBytes in interface ActiveMQBufferindex - Index into the buffersrc - The source bufferlength - the number of bytes to transferpublic void setBytes(int index,
ActiveMQBuffer src)
ActiveMQBufferindex until the destination becomes
unreadable. This method is basically same with
ActiveMQBuffer.setBytes(int, ActiveMQBuffer, int, int), except that this
method increases the readerIndex of the source buffer by
the number of the transferred bytes while
ActiveMQBuffer.getBytes(int, ActiveMQBuffer, int, int) does not.
This method does not modify readerIndex or writerIndex of
the source buffer (i.e. this).setBytes in interface ActiveMQBufferindex - Index into the buffersrc - The source bufferpublic void setChar(int index,
char value)
ActiveMQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setChar in interface ActiveMQBufferindex - Index into the buffervalue - The specified charpublic void setDouble(int index,
double value)
ActiveMQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setDouble in interface ActiveMQBufferindex - Index into the buffervalue - The specified doublepublic void setFloat(int index,
float value)
ActiveMQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setFloat in interface ActiveMQBufferindex - Index into the buffervalue - The specified floatpublic void setIndex(int readerIndex,
int writerIndex)
ActiveMQBufferreaderIndex and writerIndex of this buffer
in one shot. This method is useful when you have to worry about the
invocation order of ActiveMQBuffer.readerIndex(int) and ActiveMQBuffer.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,
ActiveMQBuffer.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 ActiveMQBufferreaderIndex - The reader's indexwriterIndex - The writer's indexpublic void setInt(int index,
int value)
ActiveMQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setInt in interface ActiveMQBufferindex - Index into the buffervalue - The specified 32-bit integerpublic void setLong(int index,
long value)
ActiveMQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setLong in interface ActiveMQBufferindex - Index into the buffervalue - The specified 64-bit long integerpublic void setShort(int index,
short value)
ActiveMQBufferindex in this buffer.
This method does not modify readerIndex or writerIndex of
this buffer.setShort in interface ActiveMQBufferindex - Index into the buffervalue - The specified 16-bit short integerpublic int skipBytes(int length)
ActiveMQBufferreaderIndex by the specified
length in this buffer.skipBytes in interface DataInputskipBytes in interface ActiveMQBufferlength - The number of bytes to skippublic ActiveMQBuffer slice()
ActiveMQBufferbuf.slice(buf.readerIndex(), buf.readableBytes()).
This method does not modify readerIndex or writerIndex of
this buffer.slice in interface ActiveMQBufferpublic ActiveMQBuffer slice(int index, int length)
ActiveMQBufferreaderIndex or writerIndex of
this buffer.slice in interface ActiveMQBufferindex - Index into the bufferlength - The number of bytespublic ByteBuffer toByteBuffer()
ActiveMQBufferbuf.toByteBuffer(buf.readerIndex(), buf.readableBytes()).
This method does not modify readerIndex or writerIndex of
this buffer.toByteBuffer in interface ActiveMQBufferpublic ByteBuffer toByteBuffer(int index, int length)
ActiveMQBufferreaderIndex or writerIndex of
this buffer.toByteBuffer in interface ActiveMQBufferindex - Index into the bufferlength - The number of bytespublic void release()
ActiveMQBufferrelease in interface ActiveMQBufferpublic boolean writable()
writable in interface ActiveMQBuffertrueif and only if (this.capacity - this.writerIndex) is greater than 0.public int writableBytes()
writableBytes in interface ActiveMQBuffer(this.capacity - this.writerIndex).public void writeByte(byte value)
ActiveMQBufferwriterIndex
and increases the writerIndex by 1 in this buffer.writeByte in interface ActiveMQBuffervalue - The specified bytepublic void writeBytes(byte[] src,
int srcIndex,
int length)
ActiveMQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= length).writeBytes in interface ActiveMQBuffersrc - The source buffersrcIndex - the first index of the sourcelength - the number of bytes to transferpublic void writeBytes(byte[] src)
ActiveMQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= src.length).writeBytes in interface ActiveMQBuffersrc - The source bufferpublic void writeBytes(ByteBuffer src)
ActiveMQBufferwriterIndex until the source buffer's position
reaches its limit, and increases the writerIndex by the
number of the transferred bytes.writeBytes in interface ActiveMQBuffersrc - The source bufferpublic void writeBytes(io.netty.buffer.ByteBuf src,
int srcIndex,
int length)
ActiveMQBufferwriterIndex until the source buffer's position
reaches its limit, and increases the writerIndex by the
number of the transferred bytes.writeBytes in interface ActiveMQBuffersrc - The source bufferpublic void writeBytes(ActiveMQBuffer src, int srcIndex, int length)
ActiveMQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= length).writeBytes in interface ActiveMQBuffersrc - The source buffersrcIndex - the first index of the sourcelength - the number of bytes to transferpublic void writeBytes(ActiveMQBuffer src, int length)
ActiveMQBufferwriterIndex and increases the writerIndex
by the number of the transferred bytes (= length). This method
is basically same with ActiveMQBuffer.writeBytes(ActiveMQBuffer, int, int),
except that this method increases the readerIndex of the source
buffer by the number of the transferred bytes (= length) while
ActiveMQBuffer.writeBytes(ActiveMQBuffer, int, int) does not.writeBytes in interface ActiveMQBuffersrc - The source bufferlength - the number of bytes to transferpublic void writeChar(char chr)
ActiveMQBufferwriterIndex
and increases the writerIndex by 2 in this buffer.writeChar in interface ActiveMQBufferchr - The specified charpublic void writeDouble(double value)
ActiveMQBufferwriterIndex
and increases the writerIndex by 8 in this buffer.writeDouble in interface ActiveMQBuffervalue - The specified doublepublic void writeFloat(float value)
ActiveMQBufferwriterIndex
and increases the writerIndex by 4 in this buffer.writeFloat in interface ActiveMQBuffervalue - The specified floatpublic void writeInt(int value)
ActiveMQBufferwriterIndex
and increases the writerIndex by 4 in this buffer.writeInt in interface ActiveMQBuffervalue - The specified 32-bit integerpublic void writeNullableInt(Integer value)
ActiveMQBuffernull) 32-bit integer at the current writerIndex
and increases the writerIndex by 4 in this buffer.writeNullableInt in interface ActiveMQBuffervalue - The specified (potentially null) 32-bit integerpublic void writeLong(long value)
ActiveMQBufferwriterIndex and increases the writerIndex by 8
in this buffer.writeLong in interface ActiveMQBuffervalue - The specified 64-bit long integerpublic void writeNullableLong(Long value)
ActiveMQBuffernull) 64-bit long integer at the current
writerIndex and increases the writerIndex by 8
in this buffer.writeNullableLong in interface ActiveMQBuffervalue - The specified (potentially null) 64-bit long integerpublic int writerIndex()
writerIndex in interface ActiveMQBufferwriterIndex of this buffer.public void writerIndex(int writerIndex)
ActiveMQBufferwriterIndex of this buffer.writerIndex in interface ActiveMQBufferwriterIndex - The writer's indexpublic void writeShort(short value)
ActiveMQBufferwriterIndex and increases the writerIndex by 2
in this buffer.writeShort in interface ActiveMQBuffervalue - The specified 16-bit short integerpublic void readFully(byte[] b)
throws IOException
DataInput interfacereadFully in interface DataInputIOExceptionpublic void readFully(byte[] b,
int off,
int len)
throws IOException
DataInput interfacereadFully in interface DataInputIOExceptionpublic String readLine() throws IOException
DataInput interfacereadLine in interface DataInputIOExceptionCopyright © 2021 JBoss by Red Hat. All rights reserved.