|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ChannelBuffer | |
---|---|
org.jboss.messaging.core.buffers | JBoss Messaging Buffering |
org.jboss.messaging.core.client.impl | |
org.jboss.messaging.core.journal.impl |
Uses of ChannelBuffer in org.jboss.messaging.core.buffers |
---|
Classes in org.jboss.messaging.core.buffers that implement ChannelBuffer | |
---|---|
class |
AbstractChannelBuffer
A skeletal implementation of a buffer. |
class |
ByteBufferBackedChannelBuffer
A NIO ByteBuffer based buffer. |
class |
DynamicChannelBuffer
A dynamic capacity buffer which increases its capacity as needed. |
class |
HeapChannelBuffer
A skeletal implementation for Java heap buffers. |
Methods in org.jboss.messaging.core.buffers that return ChannelBuffer | |
---|---|
static ChannelBuffer |
ChannelBuffers.buffer(int capacity)
Creates a new Java heap buffer with the specified endianness
and capacity . |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(byte[] array)
Creates a new buffer with the specified endianness whose
content is a copy of the specified array . |
static ChannelBuffer |
ChannelBuffers.copiedBuffer(java.nio.ByteBuffer buffer)
Creates a new buffer whose content is a copy of the specified buffer 's current slice. |
ChannelBuffer |
HeapChannelBuffer.copy(int index,
int length)
|
ChannelBuffer |
HeapChannelBuffer.duplicate()
|
static ChannelBuffer |
ChannelBuffers.dynamicBuffer(byte[] initialBuffer)
Reuses the initialBuffer on the creation of the DynamicBuffer. |
static ChannelBuffer |
ChannelBuffers.dynamicBuffer(int estimatedLength)
Creates a new dynamic buffer with the specified endianness and the specified estimated data length. |
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(byte[] array)
Creates a new buffer which wraps the specified array with the
specified endianness . |
static ChannelBuffer |
ChannelBuffers.wrappedBuffer(java.nio.ByteBuffer buffer)
Creates a new buffer which wraps the specified NIO buffer's current slice. |
Methods in org.jboss.messaging.core.buffers with parameters of type ChannelBuffer | |
---|---|
static int |
ChannelBuffers.compare(ChannelBuffer bufferA,
ChannelBuffer bufferB)
Compares the two specified buffers as described in compareTo(ChannelBuffer) . |
int |
AbstractChannelBuffer.compareTo(ChannelBuffer that)
|
int |
ChannelBuffer.compareTo(ChannelBuffer buffer)
Compares the content of the specified buffer to the content of this buffer. |
static boolean |
ChannelBuffers.equals(ChannelBuffer bufferA,
ChannelBuffer bufferB)
Returns true if and only if the two specified buffers are
identical to each other as described in ChannelBuffer#equals(Object) . |
void |
AbstractChannelBuffer.getBytes(int index,
ChannelBuffer dst)
|
void |
ChannelBuffer.getBytes(int index,
ChannelBuffer dst)
Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination becomes
non-writable. |
void |
AbstractChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int length)
|
void |
ChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int length)
Transfers this buffer's data to the specified destination starting at the specified absolute index . |
void |
HeapChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length)
|
void |
ByteBufferBackedChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length)
|
void |
DynamicChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length)
|
void |
ChannelBuffer.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at the specified absolute index . |
static int |
ChannelBuffers.hashCode(ChannelBuffer buffer)
Calculates the hash code of the specified buffer. |
static java.lang.String |
ChannelBuffers.hexDump(ChannelBuffer buffer)
Returns a hex dump of the specified buffer's readable bytes. |
static java.lang.String |
ChannelBuffers.hexDump(ChannelBuffer buffer,
int fromIndex,
int length)
Returns a hex dump of the specified buffer's sub-region. |
static int |
ChannelBuffers.indexOf(ChannelBuffer buffer,
int fromIndex,
int toIndex,
byte value)
The default implementation of ChannelBuffer#indexOf(int, int, byte) . |
void |
AbstractChannelBuffer.readBytes(ChannelBuffer dst)
|
void |
ChannelBuffer.readBytes(ChannelBuffer 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 |
AbstractChannelBuffer.readBytes(ChannelBuffer dst,
int length)
|
void |
ChannelBuffer.readBytes(ChannelBuffer 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 |
AbstractChannelBuffer.readBytes(ChannelBuffer dst,
int dstIndex,
int length)
|
void |
ChannelBuffer.readBytes(ChannelBuffer 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 |
AbstractChannelBuffer.setBytes(int index,
ChannelBuffer src)
|
void |
ChannelBuffer.setBytes(int index,
ChannelBuffer src)
Transfers the specified source buffer's data to this buffer starting at the specified absolute index until the destination becomes
unreadable. |
void |
AbstractChannelBuffer.setBytes(int index,
ChannelBuffer src,
int length)
|
void |
ChannelBuffer.setBytes(int index,
ChannelBuffer src,
int length)
Transfers the specified source buffer's data to this buffer starting at the specified absolute index . |
void |
HeapChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length)
|
void |
ByteBufferBackedChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length)
|
void |
DynamicChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length)
|
void |
ChannelBuffer.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at the specified absolute index . |
void |
AbstractChannelBuffer.writeBytes(ChannelBuffer src)
|
void |
ChannelBuffer.writeBytes(ChannelBuffer src)
Transfers the specified source buffer's data to this buffer starting at the current writerIndex until the source buffer becomes
unreadable, and increases the writerIndex by the number of
the transferred bytes. |
void |
AbstractChannelBuffer.writeBytes(ChannelBuffer src,
int length)
|
void |
ChannelBuffer.writeBytes(ChannelBuffer 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 |
AbstractChannelBuffer.writeBytes(ChannelBuffer src,
int srcIndex,
int length)
|
void |
DynamicChannelBuffer.writeBytes(ChannelBuffer src,
int srcIndex,
int length)
|
void |
ChannelBuffer.writeBytes(ChannelBuffer 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 ). |
Uses of ChannelBuffer in org.jboss.messaging.core.client.impl |
---|
Classes in org.jboss.messaging.core.client.impl that implement ChannelBuffer | |
---|---|
class |
LargeMessageBufferImpl
This class aggregates several SessionReceiveContinuationMessages as it was being handled by a single buffer. |
Methods in org.jboss.messaging.core.client.impl with parameters of type ChannelBuffer | |
---|---|
int |
LargeMessageBufferImpl.compareTo(ChannelBuffer buffer)
|
void |
LargeMessageBufferImpl.getBytes(int index,
ChannelBuffer dst)
|
void |
LargeMessageBufferImpl.getBytes(int index,
ChannelBuffer dst,
int length)
|
void |
LargeMessageBufferImpl.getBytes(int index,
ChannelBuffer dst,
int dstIndex,
int length)
|
void |
LargeMessageBufferImpl.getBytes(long index,
ChannelBuffer dst,
int dstIndex,
int length)
|
void |
LargeMessageBufferImpl.readBytes(ChannelBuffer dst)
|
void |
LargeMessageBufferImpl.readBytes(ChannelBuffer dst,
int length)
|
void |
LargeMessageBufferImpl.readBytes(ChannelBuffer dst,
int dstIndex,
int length)
|
void |
LargeMessageBufferImpl.setBytes(int index,
ChannelBuffer src)
|
void |
LargeMessageBufferImpl.setBytes(int index,
ChannelBuffer src,
int length)
|
void |
LargeMessageBufferImpl.setBytes(int index,
ChannelBuffer src,
int srcIndex,
int length)
|
void |
LargeMessageBufferImpl.writeBytes(ChannelBuffer src)
|
void |
LargeMessageBufferImpl.writeBytes(ChannelBuffer src,
int length)
|
void |
LargeMessageBufferImpl.writeBytes(ChannelBuffer src,
int srcIndex,
int length)
|
Uses of ChannelBuffer in org.jboss.messaging.core.journal.impl |
---|
Methods in org.jboss.messaging.core.journal.impl with parameters of type ChannelBuffer | |
---|---|
static void |
JournalImpl.writeAddRecord(int fileId,
long id,
byte recordType,
EncodingSupport record,
int size,
ChannelBuffer bb)
|
static void |
JournalImpl.writeAddRecordTX(int fileID,
long txID,
long id,
byte recordType,
EncodingSupport record,
int size,
ChannelBuffer bb)
|
static void |
JournalImpl.writeDeleteRecordTransactional(int fileID,
long txID,
long id,
EncodingSupport record,
int size,
ChannelBuffer bb)
|
static void |
JournalImpl.writeTransaction(int fileID,
byte recordType,
long txID,
JournalTransaction tx,
EncodingSupport transactionData,
int size,
int numberOfRecords,
ChannelBuffer bb)
A transaction record (Commit or Prepare), will hold the number of elements the transaction has on each file. |
static void |
JournalImpl.writeUpdateRecord(int fileId,
long id,
byte recordType,
EncodingSupport record,
int size,
ChannelBuffer bb)
|
static void |
JournalImpl.writeUpdateRecordTX(int fileID,
long txID,
long id,
byte recordType,
EncodingSupport record,
int size,
ChannelBuffer bb)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |