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) |
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. |
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. |
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 |
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 |
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 |
public ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer)
public ChannelBufferWrapper(io.netty.buffer.ByteBuf buffer, boolean releasable)
public static io.netty.buffer.ByteBuf unwrap(io.netty.buffer.ByteBuf buffer)
public boolean readBoolean()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 1
in this buffer.readBoolean
in interface DataInput
readBoolean
in interface ActiveMQBuffer
readerIndex
public SimpleString readNullableSimpleString()
ActiveMQBuffer
null
) at the current readerIndex
readNullableSimpleString
in interface ActiveMQBuffer
null
) at the current readerIndex
public String readNullableString()
ActiveMQBuffer
null
) at the current readerIndex
readNullableString
in interface ActiveMQBuffer
null
) at the current readerIndex
public SimpleString readSimpleString()
ActiveMQBuffer
readerIndex
readSimpleString
in interface ActiveMQBuffer
readerIndex
public String readString()
ActiveMQBuffer
readerIndex
readString
in interface ActiveMQBuffer
readerIndex
public String readUTF()
ActiveMQBuffer
readerIndex
readUTF
in interface DataInput
readUTF
in interface ActiveMQBuffer
readerIndex
public void writeBoolean(boolean val)
ActiveMQBuffer
writerIndex
writeBoolean
in interface ActiveMQBuffer
val
- The specified booleanpublic void writeNullableSimpleString(SimpleString val)
ActiveMQBuffer
null
) at the current writerIndex
writeNullableSimpleString
in interface ActiveMQBuffer
val
- The specified SimpleStringpublic void writeNullableString(String val)
ActiveMQBuffer
null
) at the current writerIndex
writeNullableString
in interface ActiveMQBuffer
val
- The specified Stringpublic void writeSimpleString(SimpleString val)
ActiveMQBuffer
writerIndex
writeSimpleString
in interface ActiveMQBuffer
val
- The specified non-null SimpleStringpublic void writeString(String val)
ActiveMQBuffer
writerIndex
writeString
in interface ActiveMQBuffer
val
- The specified non-null Stringpublic void writeUTF(String utf)
ActiveMQBuffer
writerIndex
writeUTF
in interface ActiveMQBuffer
utf
- The specified UTF-8 Stringpublic int capacity()
ActiveMQBuffer
capacity
in interface ActiveMQBuffer
public io.netty.buffer.ByteBuf byteBuf()
ActiveMQBuffer
byteBuf
in interface ActiveMQBuffer
public void clear()
ActiveMQBuffer
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.
clear
in interface ActiveMQBuffer
public ActiveMQBuffer copy()
ActiveMQBuffer
buf.copy(buf.readerIndex(), buf.readableBytes())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.copy
in interface ActiveMQBuffer
public ActiveMQBuffer copy(int index, int length)
ActiveMQBuffer
readerIndex
or writerIndex
of
this buffer.copy
in interface ActiveMQBuffer
index
- Index into the bufferlength
- The number of bytes to copypublic void discardReadBytes()
ActiveMQBuffer
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.
discardReadBytes
in interface ActiveMQBuffer
public ActiveMQBuffer duplicate()
ActiveMQBuffer
buf.slice(0, buf.capacity())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.duplicate
in interface ActiveMQBuffer
public byte getByte(int index)
ActiveMQBuffer
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.getByte
in interface ActiveMQBuffer
index
- Index into the bufferpublic void getBytes(int index, byte[] dst, int dstIndex, int length)
ActiveMQBuffer
index
.
This method does not modify readerIndex
or writerIndex
of this buffer.getBytes
in interface ActiveMQBuffer
index
- 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)
ActiveMQBuffer
index
.
This method does not modify readerIndex
or writerIndex
of
this buffergetBytes
in interface ActiveMQBuffer
index
- Index into the bufferdst
- The destination bufferpublic void getBytes(int index, ByteBuffer dst)
ActiveMQBuffer
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.getBytes
in interface ActiveMQBuffer
index
- Index into the bufferdst
- The destination bufferpublic void getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)
ActiveMQBuffer
index
.
This method does not modify readerIndex
or writerIndex
of both the source (i.e. this
) and the destination.getBytes
in interface ActiveMQBuffer
index
- 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)
ActiveMQBuffer
index
. 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 ActiveMQBuffer
index
- Index into the bufferdst
- The destination bufferlength
- the number of bytes to transferpublic void getBytes(int index, ActiveMQBuffer dst)
ActiveMQBuffer
index
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 ActiveMQBuffer
index
- Index into the bufferdst
- The destination bufferpublic char getChar(int index)
ActiveMQBuffer
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getChar
in interface ActiveMQBuffer
index
- Index into the bufferindex
public double getDouble(int index)
ActiveMQBuffer
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getDouble
in interface ActiveMQBuffer
index
- Index into the bufferindex
public float getFloat(int index)
ActiveMQBuffer
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getFloat
in interface ActiveMQBuffer
index
- Index into the bufferindex
public int getInt(int index)
ActiveMQBuffer
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getInt
in interface ActiveMQBuffer
index
- Index into the bufferindex
public long getLong(int index)
ActiveMQBuffer
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getLong
in interface ActiveMQBuffer
index
- Index into the bufferindex
public short getShort(int index)
ActiveMQBuffer
index
in
this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getShort
in interface ActiveMQBuffer
index
- Index into the bufferindex
public short getUnsignedByte(int index)
ActiveMQBuffer
index
in this
buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getUnsignedByte
in interface ActiveMQBuffer
index
- Index into the bufferindex
public long getUnsignedInt(int index)
ActiveMQBuffer
index
in this buffer. This method does not modify readerIndex
or
writerIndex
of this buffer.getUnsignedInt
in interface ActiveMQBuffer
index
- The index into this bufferindex
public int getUnsignedShort(int index)
ActiveMQBuffer
index
in this buffer. This method does not modify
readerIndex
or writerIndex
of this buffer.getUnsignedShort
in interface ActiveMQBuffer
index
- Index into the bufferpublic void markReaderIndex()
ActiveMQBuffer
readerIndex
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 ActiveMQBuffer
public void markWriterIndex()
ActiveMQBuffer
writerIndex
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 ActiveMQBuffer
public boolean readable()
readable
in interface ActiveMQBuffer
true
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()
ActiveMQBuffer
readerIndex
and increases
the readerIndex
by 1
in this buffer.readByte
in interface DataInput
readByte
in interface ActiveMQBuffer
readerIndex
public void readBytes(byte[] dst, int dstIndex, int length)
ActiveMQBuffer
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).readBytes
in interface ActiveMQBuffer
dst
- The destination bufferdstIndex
- The destination bufferIndexlength
- the number of bytes to transferpublic void readBytes(byte[] dst)
ActiveMQBuffer
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= dst.length
).readBytes
in interface ActiveMQBuffer
dst
- The destination bufferpublic void readBytes(ByteBuffer dst)
ActiveMQBuffer
readerIndex
until the destination's position
reaches its limit, and increases the readerIndex
by the
number of the transferred bytes.readBytes
in interface ActiveMQBuffer
dst
- The destination bufferpublic void readBytes(ActiveMQBuffer dst, int dstIndex, int length)
ActiveMQBuffer
readerIndex
and increases the readerIndex
by the number of the transferred bytes (= length
).readBytes
in interface ActiveMQBuffer
dst
- The destination bufferdstIndex
- The destination buffer indexlength
- the number of bytes to transferpublic void readBytes(ActiveMQBuffer dst, int length)
ActiveMQBuffer
readerIndex
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 ActiveMQBuffer
dst
- The destination bufferlength
- The number of bytes to transferpublic void readBytes(ActiveMQBuffer dst)
ActiveMQBuffer
readerIndex
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 ActiveMQBuffer
dst
- The destination bufferpublic ActiveMQBuffer readBytes(int length)
ActiveMQBuffer
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.readBytes
in interface ActiveMQBuffer
length
- the number of bytes to transferpublic char readChar()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 2
in this buffer.readChar
in interface DataInput
readChar
in interface ActiveMQBuffer
readerIndex
public double readDouble()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 8
in this buffer.readDouble
in interface DataInput
readDouble
in interface ActiveMQBuffer
readerIndex
public int readerIndex()
readerIndex
in interface ActiveMQBuffer
readerIndex
of this buffer.public void readerIndex(int readerIndex)
ActiveMQBuffer
readerIndex
of this buffer.readerIndex
in interface ActiveMQBuffer
readerIndex
- The reader's index The reader infexpublic float readFloat()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 4
in this buffer.readFloat
in interface DataInput
readFloat
in interface ActiveMQBuffer
readerIndex
public int readInt()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 4
in this buffer.readInt
in interface DataInput
readInt
in interface ActiveMQBuffer
readerIndex
public long readLong()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 8
in this buffer.readLong
in interface DataInput
readLong
in interface ActiveMQBuffer
readerIndex
public short readShort()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 2
in this buffer.readShort
in interface DataInput
readShort
in interface ActiveMQBuffer
readerIndex
public ActiveMQBuffer readSlice(int length)
ActiveMQBuffer
readerIndex
and increases the readerIndex
by the size
of the new slice (= length
).readSlice
in interface ActiveMQBuffer
length
- the size of the new slicepublic int readUnsignedByte()
ActiveMQBuffer
readerIndex
and increases
the readerIndex
by 1
in this buffer.readUnsignedByte
in interface DataInput
readUnsignedByte
in interface ActiveMQBuffer
readerIndex
public long readUnsignedInt()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 4
in this buffer.readUnsignedInt
in interface ActiveMQBuffer
readerIndex
public int readUnsignedShort()
ActiveMQBuffer
readerIndex
and increases the readerIndex
by 2
in this buffer.readUnsignedShort
in interface DataInput
readUnsignedShort
in interface ActiveMQBuffer
readerIndex
public void resetReaderIndex()
ActiveMQBuffer
readerIndex
to the marked
readerIndex
in this buffer.resetReaderIndex
in interface ActiveMQBuffer
public void resetWriterIndex()
ActiveMQBuffer
writerIndex
to the marked
writerIndex
in this buffer.resetWriterIndex
in interface ActiveMQBuffer
public void setByte(int index, byte value)
ActiveMQBuffer
index
in this
buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.setByte
in interface ActiveMQBuffer
index
- Index into the buffervalue
- The specified bytepublic void setBytes(int index, byte[] src, int srcIndex, int length)
ActiveMQBuffer
index
.
This method does not modify readerIndex
or writerIndex
of
this buffer.setBytes
in interface ActiveMQBuffer
index
- Index into the buffersrc
- The source buffersrcIndex
- The source buffer indexlength
- The number of bytes to transferpublic void setBytes(int index, byte[] src)
ActiveMQBuffer
index
.
This method does not modify readerIndex
or writerIndex
of
this buffer.setBytes
in interface ActiveMQBuffer
index
- Index into the buffersrc
- The source bufferpublic void setBytes(int index, ByteBuffer src)
ActiveMQBuffer
index
until the source buffer's position
reaches its limit.
This method does not modify readerIndex
or writerIndex
of
this buffer.setBytes
in interface ActiveMQBuffer
index
- Index into the buffersrc
- The source bufferpublic void setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
ActiveMQBuffer
index
.
This method does not modify readerIndex
or writerIndex
of both the source (i.e. this
) and the destination.setBytes
in interface ActiveMQBuffer
index
- 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)
ActiveMQBuffer
index
. 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 ActiveMQBuffer
index
- Index into the buffersrc
- The source bufferlength
- the number of bytes to transferpublic void setBytes(int index, ActiveMQBuffer src)
ActiveMQBuffer
index
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 ActiveMQBuffer
index
- Index into the buffersrc
- The source bufferpublic void setChar(int index, char value)
ActiveMQBuffer
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.setChar
in interface ActiveMQBuffer
index
- Index into the buffervalue
- The specified charpublic void setDouble(int index, double value)
ActiveMQBuffer
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.setDouble
in interface ActiveMQBuffer
index
- Index into the buffervalue
- The specified doublepublic void setFloat(int index, float value)
ActiveMQBuffer
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.setFloat
in interface ActiveMQBuffer
index
- Index into the buffervalue
- The specified floatpublic void setIndex(int readerIndex, int writerIndex)
ActiveMQBuffer
readerIndex
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 ActiveMQBuffer
readerIndex
- The reader's indexwriterIndex
- The writer's indexpublic void setInt(int index, int value)
ActiveMQBuffer
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.setInt
in interface ActiveMQBuffer
index
- Index into the buffervalue
- The specified 32-bit integerpublic void setLong(int index, long value)
ActiveMQBuffer
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.setLong
in interface ActiveMQBuffer
index
- Index into the buffervalue
- The specified 64-bit long integerpublic void setShort(int index, short value)
ActiveMQBuffer
index
in this buffer.
This method does not modify readerIndex
or writerIndex
of
this buffer.setShort
in interface ActiveMQBuffer
index
- Index into the buffervalue
- The specified 16-bit short integerpublic int skipBytes(int length)
ActiveMQBuffer
readerIndex
by the specified
length
in this buffer.skipBytes
in interface DataInput
skipBytes
in interface ActiveMQBuffer
length
- The number of bytes to skippublic ActiveMQBuffer slice()
ActiveMQBuffer
buf.slice(buf.readerIndex(), buf.readableBytes())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.slice
in interface ActiveMQBuffer
public ActiveMQBuffer slice(int index, int length)
ActiveMQBuffer
readerIndex
or writerIndex
of
this buffer.slice
in interface ActiveMQBuffer
index
- Index into the bufferlength
- The number of bytespublic ByteBuffer toByteBuffer()
ActiveMQBuffer
buf.toByteBuffer(buf.readerIndex(), buf.readableBytes())
.
This method does not modify readerIndex
or writerIndex
of
this buffer.toByteBuffer
in interface ActiveMQBuffer
public ByteBuffer toByteBuffer(int index, int length)
ActiveMQBuffer
readerIndex
or writerIndex
of
this buffer.toByteBuffer
in interface ActiveMQBuffer
index
- Index into the bufferlength
- The number of bytespublic boolean writable()
writable
in interface ActiveMQBuffer
true
if 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)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by 1
in this buffer.writeByte
in interface ActiveMQBuffer
value
- The specified bytepublic void writeBytes(byte[] src, int srcIndex, int length)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
).writeBytes
in interface ActiveMQBuffer
src
- The source buffersrcIndex
- the first index of the sourcelength
- the number of bytes to transferpublic void writeBytes(byte[] src)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= src.length
).writeBytes
in interface ActiveMQBuffer
src
- The source bufferpublic void writeBytes(ByteBuffer src)
ActiveMQBuffer
writerIndex
until the source buffer's position
reaches its limit, and increases the writerIndex
by the
number of the transferred bytes.writeBytes
in interface ActiveMQBuffer
src
- The source bufferpublic void writeBytes(ActiveMQBuffer src, int srcIndex, int length)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by the number of the transferred bytes (= length
).writeBytes
in interface ActiveMQBuffer
src
- The source buffersrcIndex
- the first index of the sourcelength
- the number of bytes to transferpublic void writeBytes(ActiveMQBuffer src, int length)
ActiveMQBuffer
writerIndex
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 ActiveMQBuffer
src
- The source bufferlength
- the number of bytes to transferpublic void writeChar(char chr)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by 2
in this buffer.writeChar
in interface ActiveMQBuffer
chr
- The specified charpublic void writeDouble(double value)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by 8
in this buffer.writeDouble
in interface ActiveMQBuffer
value
- The specified doublepublic void writeFloat(float value)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by 4
in this buffer.writeFloat
in interface ActiveMQBuffer
value
- The specified floatpublic void writeInt(int value)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by 4
in this buffer.writeInt
in interface ActiveMQBuffer
value
- The specified 32-bit integerpublic void writeLong(long value)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by 8
in this buffer.writeLong
in interface ActiveMQBuffer
value
- The specified 64-bit long integerpublic int writerIndex()
writerIndex
in interface ActiveMQBuffer
writerIndex
of this buffer.public void writerIndex(int writerIndex)
ActiveMQBuffer
writerIndex
of this buffer.writerIndex
in interface ActiveMQBuffer
writerIndex
- The writer's indexpublic void writeShort(short value)
ActiveMQBuffer
writerIndex
and increases the writerIndex
by 2
in this buffer.writeShort
in interface ActiveMQBuffer
value
- The specified 16-bit short integerpublic void readFully(byte[] b) throws IOException
DataInput
interfacereadFully
in interface DataInput
IOException
public void readFully(byte[] b, int off, int len) throws IOException
DataInput
interfacereadFully
in interface DataInput
IOException
public String readLine() throws IOException
DataInput
interfacereadLine
in interface DataInput
IOException
Copyright © 2016 JBoss by Red Hat. All rights reserved.