Package | Description |
---|---|
org.apache.activemq.artemis.api.core | |
org.apache.activemq.artemis.core.buffers.impl | |
org.apache.activemq.artemis.utils |
Modifier and Type | Method and Description |
---|---|
ActiveMQBuffer |
ActiveMQBuffer.copy()
Returns a copy of this buffer's readable bytes.
|
ActiveMQBuffer |
ActiveMQBuffer.copy(int index,
int length)
Returns a copy of this buffer's sub-region.
|
ActiveMQBuffer |
ActiveMQBuffer.duplicate()
Returns a buffer which shares the whole region of this buffer.
|
static ActiveMQBuffer |
ActiveMQBuffers.dynamicBuffer(byte[] bytes)
Creates a self-expanding ActiveMQBuffer filled with the given byte array
|
static ActiveMQBuffer |
ActiveMQBuffers.dynamicBuffer(int size)
Creates a self-expanding ActiveMQBuffer with the given initial size
|
static ActiveMQBuffer |
ActiveMQBuffers.fixedBuffer(int size)
Creates a fixed ActiveMQBuffer of the given size
|
static ActiveMQBuffer |
ActiveMQBuffers.pooledBuffer(int size) |
ActiveMQBuffer |
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 ). |
ActiveMQBuffer |
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 ). |
ActiveMQBuffer |
ActiveMQBuffer.slice()
Returns a slice of this buffer's readable bytes.
|
ActiveMQBuffer |
ActiveMQBuffer.slice(int index,
int length)
Returns a slice of this buffer's sub-region.
|
static ActiveMQBuffer |
ActiveMQBuffers.wrappedBuffer(byte[] underlying)
Creates an ActiveMQBuffer wrapping an underlying byte array
|
static ActiveMQBuffer |
ActiveMQBuffers.wrappedBuffer(ByteBuffer underlying)
Creates an ActiveMQBuffer wrapping an underlying NIO ByteBuffer
The position on this buffer won't affect the position on the inner buffer
|
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQBuffer.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 |
ActiveMQBuffer.getBytes(int index,
ActiveMQBuffer dst,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
void |
ActiveMQBuffer.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 |
ActiveMQBuffer.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 |
ActiveMQBuffer.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 |
ActiveMQBuffer.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 |
ActiveMQBuffer.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 |
ActiveMQBuffer.setBytes(int index,
ActiveMQBuffer src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
void |
ActiveMQBuffer.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 |
ActiveMQBuffer.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 |
ActiveMQBuffer.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 ). |
Modifier and Type | Class and Description |
---|---|
class |
ChannelBufferWrapper |
Modifier and Type | Method and Description |
---|---|
ActiveMQBuffer |
ChannelBufferWrapper.copy() |
ActiveMQBuffer |
ChannelBufferWrapper.copy(int index,
int length) |
ActiveMQBuffer |
ChannelBufferWrapper.duplicate() |
ActiveMQBuffer |
ChannelBufferWrapper.readBytes(int length) |
ActiveMQBuffer |
ChannelBufferWrapper.readSlice(int length) |
ActiveMQBuffer |
ChannelBufferWrapper.slice() |
ActiveMQBuffer |
ChannelBufferWrapper.slice(int index,
int length) |
Modifier and Type | Method and Description |
---|---|
void |
ChannelBufferWrapper.getBytes(int index,
ActiveMQBuffer dst) |
void |
ChannelBufferWrapper.getBytes(int index,
ActiveMQBuffer dst,
int length) |
void |
ChannelBufferWrapper.getBytes(int index,
ActiveMQBuffer dst,
int dstIndex,
int length) |
void |
ChannelBufferWrapper.readBytes(ActiveMQBuffer dst) |
void |
ChannelBufferWrapper.readBytes(ActiveMQBuffer dst,
int length) |
void |
ChannelBufferWrapper.readBytes(ActiveMQBuffer dst,
int dstIndex,
int length) |
void |
ChannelBufferWrapper.setBytes(int index,
ActiveMQBuffer src) |
void |
ChannelBufferWrapper.setBytes(int index,
ActiveMQBuffer src,
int length) |
void |
ChannelBufferWrapper.setBytes(int index,
ActiveMQBuffer src,
int srcIndex,
int length) |
void |
ChannelBufferWrapper.writeBytes(ActiveMQBuffer src,
int length) |
void |
ChannelBufferWrapper.writeBytes(ActiveMQBuffer src,
int srcIndex,
int length) |
Modifier and Type | Method and Description |
---|---|
static ActiveMQBuffer |
RandomUtil.randomBuffer(int size,
long... data) |
Modifier and Type | Method and Description |
---|---|
void |
TypedProperties.decode(ActiveMQBuffer buffer) |
void |
TypedProperties.encode(ActiveMQBuffer buffer) |
static String |
ByteUtil.readLine(ActiveMQBuffer buffer) |
static String |
UTF8Util.readUTF(ActiveMQBuffer input) |
static void |
UTF8Util.saveUTF(ActiveMQBuffer out,
String str) |
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.