Package | Description |
---|---|
org.hornetq.api.core |
Core Messaging API.
|
org.hornetq.spi.core.protocol | |
org.hornetq.spi.core.remoting |
Remoting SPI.
|
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
HornetQBuffer.copy()
Returns a copy of this buffer's readable bytes.
|
HornetQBuffer |
HornetQBuffer.copy(int index,
int length)
Returns a copy of this buffer's sub-region.
|
HornetQBuffer |
HornetQBuffer.duplicate()
Returns a buffer which shares the whole region of this buffer.
|
static HornetQBuffer |
HornetQBuffers.dynamicBuffer(byte[] bytes)
Creates a self-expanding HornetQBuffer filled with the given byte array
|
static HornetQBuffer |
HornetQBuffers.dynamicBuffer(int size)
Creates a self-expanding HornetQBuffer with the given initial size
|
static HornetQBuffer |
HornetQBuffers.fixedBuffer(int size)
Creates a fixed HornetQBuffer of the given size
|
HornetQBuffer |
Message.getBodyBuffer()
Returns the message body as a HornetQBuffer
|
HornetQBuffer |
HornetQBuffer.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 ). |
HornetQBuffer |
HornetQBuffer.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 ). |
HornetQBuffer |
HornetQBuffer.slice()
Returns a slice of this buffer's readable bytes.
|
HornetQBuffer |
HornetQBuffer.slice(int index,
int length)
Returns a slice of this buffer's sub-region.
|
static HornetQBuffer |
HornetQBuffers.wrappedBuffer(byte[] underlying)
Creates a HornetQBuffer wrapping an underlying byte array
|
static HornetQBuffer |
HornetQBuffers.wrappedBuffer(java.nio.ByteBuffer underlying)
Creates a HornetQBuffer 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 |
TransportConfiguration.decode(HornetQBuffer buffer)
Decodes this TransportConfiguration from a buffer.
|
void |
TransportConfiguration.encode(HornetQBuffer buffer)
Encodes this TransportConfiguration into a buffer.
|
void |
HornetQBuffer.getBytes(int index,
HornetQBuffer dst)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index until the destination becomes
non-writable. |
void |
HornetQBuffer.getBytes(int index,
HornetQBuffer dst,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
void |
HornetQBuffer.getBytes(int index,
HornetQBuffer dst,
int dstIndex,
int length)
Transfers this buffer's data to the specified destination starting at
the specified absolute
index . |
void |
HornetQBuffer.readBytes(HornetQBuffer 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 |
HornetQBuffer.readBytes(HornetQBuffer 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 |
HornetQBuffer.readBytes(HornetQBuffer 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 |
HornetQBuffer.setBytes(int index,
HornetQBuffer src)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index until the destination becomes
unreadable. |
void |
HornetQBuffer.setBytes(int index,
HornetQBuffer src,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
void |
HornetQBuffer.setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length)
Transfers the specified source buffer's data to this buffer starting at
the specified absolute
index . |
void |
HornetQBuffer.writeBytes(HornetQBuffer 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 |
HornetQBuffer.writeBytes(HornetQBuffer 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 | Method and Description |
---|---|
HornetQBuffer |
RemotingConnection.createBuffer(int size)
creates a new HornetQBuffer of the specified size.
|
Modifier and Type | Method and Description |
---|---|
void |
ProtocolManager.handleBuffer(RemotingConnection connection,
HornetQBuffer buffer) |
int |
ProtocolManager.isReadyToHandle(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
Connection.createBuffer(int size)
Create a new HornetQBuffer of the given size.
|
Modifier and Type | Method and Description |
---|---|
void |
BufferHandler.bufferReceived(java.lang.Object connectionID,
HornetQBuffer buffer)
called by the remoting connection when a buffer is received.
|
int |
BufferDecoder.isReadyToHandle(HornetQBuffer buffer)
called by the remoting system prior to
BufferHandler.bufferReceived(Object, org.hornetq.api.core.HornetQBuffer) . |
void |
Connection.write(HornetQBuffer buffer)
writes the buffer to the connection with no flushing or batching
|
void |
Connection.write(HornetQBuffer buffer,
boolean flush,
boolean batched)
writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.
|
Copyright © 2009 Red Hat Inc. All Rights Reserved.