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(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 | Class and Description |
---|---|
class |
ChannelBufferWrapper
A ChannelBufferWrapper
|
class |
ResetLimitWrappedHornetQBuffer
A ResetLimitWrappedHornetQBuffer
|
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
ChannelBufferWrapper.copy() |
HornetQBuffer |
ChannelBufferWrapper.copy(int index,
int length) |
HornetQBuffer |
ChannelBufferWrapper.duplicate() |
HornetQBuffer |
ChannelBufferWrapper.readBytes(int length) |
HornetQBuffer |
ChannelBufferWrapper.readSlice(int length) |
HornetQBuffer |
ChannelBufferWrapper.slice() |
HornetQBuffer |
ChannelBufferWrapper.slice(int index,
int length) |
Modifier and Type | Method and Description |
---|---|
void |
ChannelBufferWrapper.getBytes(int index,
HornetQBuffer dst) |
void |
ChannelBufferWrapper.getBytes(int index,
HornetQBuffer dst,
int length) |
void |
ChannelBufferWrapper.getBytes(int index,
HornetQBuffer dst,
int dstIndex,
int length) |
void |
ChannelBufferWrapper.readBytes(HornetQBuffer dst) |
void |
ChannelBufferWrapper.readBytes(HornetQBuffer dst,
int length) |
void |
ChannelBufferWrapper.readBytes(HornetQBuffer dst,
int dstIndex,
int length) |
void |
ResetLimitWrappedHornetQBuffer.setBuffer(HornetQBuffer buffer) |
void |
ResetLimitWrappedHornetQBuffer.setBytes(int index,
HornetQBuffer src) |
void |
ChannelBufferWrapper.setBytes(int index,
HornetQBuffer src) |
void |
ResetLimitWrappedHornetQBuffer.setBytes(int index,
HornetQBuffer src,
int length) |
void |
ChannelBufferWrapper.setBytes(int index,
HornetQBuffer src,
int length) |
void |
ResetLimitWrappedHornetQBuffer.setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length) |
void |
ChannelBufferWrapper.setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length) |
void |
ResetLimitWrappedHornetQBuffer.writeBytes(HornetQBuffer src,
int length) |
void |
ChannelBufferWrapper.writeBytes(HornetQBuffer src,
int length) |
void |
ResetLimitWrappedHornetQBuffer.writeBytes(HornetQBuffer src,
int srcIndex,
int length) |
void |
ChannelBufferWrapper.writeBytes(HornetQBuffer src,
int srcIndex,
int length) |
Constructor and Description |
---|
ResetLimitWrappedHornetQBuffer(int limit,
HornetQBuffer buffer,
MessageInternal message) |
Modifier and Type | Interface and Description |
---|---|
interface |
LargeMessageController
A LargeMessageBufferInternal
|
Modifier and Type | Class and Description |
---|---|
class |
CompressedLargeMessageControllerImpl
A DecompressedHornetQBuffer
|
class |
LargeMessageControllerImpl
This class aggregates several SessionReceiveContinuationMessages as it was being handled by a single buffer.
|
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
LargeMessageControllerImpl.copy() |
HornetQBuffer |
CompressedLargeMessageControllerImpl.copy() |
HornetQBuffer |
LargeMessageControllerImpl.copy(int index,
int length) |
HornetQBuffer |
CompressedLargeMessageControllerImpl.copy(int index,
int length) |
HornetQBuffer |
LargeMessageControllerImpl.duplicate() |
HornetQBuffer |
CompressedLargeMessageControllerImpl.duplicate() |
HornetQBuffer |
ClientLargeMessageImpl.getBodyBuffer() |
HornetQBuffer |
LargeMessageControllerImpl.readBytes(int length) |
HornetQBuffer |
CompressedLargeMessageControllerImpl.readBytes(int length) |
HornetQBuffer |
LargeMessageControllerImpl.readSlice(int length) |
HornetQBuffer |
CompressedLargeMessageControllerImpl.readSlice(int length) |
HornetQBuffer |
LargeMessageControllerImpl.slice() |
HornetQBuffer |
CompressedLargeMessageControllerImpl.slice() |
HornetQBuffer |
LargeMessageControllerImpl.slice(int index,
int length) |
HornetQBuffer |
CompressedLargeMessageControllerImpl.slice(int index,
int length) |
Modifier and Type | Method and Description |
---|---|
int |
LargeMessageControllerImpl.compareTo(HornetQBuffer buffer) |
int |
CompressedLargeMessageControllerImpl.compareTo(HornetQBuffer buffer) |
void |
LargeMessageControllerImpl.getBytes(int index,
HornetQBuffer dst) |
void |
CompressedLargeMessageControllerImpl.getBytes(int index,
HornetQBuffer dst) |
void |
LargeMessageControllerImpl.getBytes(int index,
HornetQBuffer dst,
int length) |
void |
CompressedLargeMessageControllerImpl.getBytes(int index,
HornetQBuffer dst,
int length) |
void |
LargeMessageControllerImpl.getBytes(int index,
HornetQBuffer dst,
int dstIndex,
int length) |
void |
CompressedLargeMessageControllerImpl.getBytes(int index,
HornetQBuffer dst,
int dstIndex,
int length) |
void |
LargeMessageControllerImpl.getBytes(long index,
HornetQBuffer dst,
int dstIndex,
int length) |
void |
CompressedLargeMessageControllerImpl.getBytes(long index,
HornetQBuffer dst,
int dstIndex,
int length) |
void |
LargeMessageControllerImpl.readBytes(HornetQBuffer dst) |
void |
CompressedLargeMessageControllerImpl.readBytes(HornetQBuffer dst) |
void |
LargeMessageControllerImpl.readBytes(HornetQBuffer dst,
int length) |
void |
CompressedLargeMessageControllerImpl.readBytes(HornetQBuffer dst,
int length) |
void |
LargeMessageControllerImpl.readBytes(HornetQBuffer dst,
int dstIndex,
int length) |
void |
CompressedLargeMessageControllerImpl.readBytes(HornetQBuffer dst,
int dstIndex,
int length) |
void |
ClientMessageInternal.setBuffer(HornetQBuffer buffer) |
void |
ClientMessageImpl.setBuffer(HornetQBuffer buffer) |
void |
LargeMessageControllerImpl.setBytes(int index,
HornetQBuffer src) |
void |
CompressedLargeMessageControllerImpl.setBytes(int index,
HornetQBuffer src) |
void |
LargeMessageControllerImpl.setBytes(int index,
HornetQBuffer src,
int length) |
void |
CompressedLargeMessageControllerImpl.setBytes(int index,
HornetQBuffer src,
int length) |
void |
LargeMessageControllerImpl.setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length) |
void |
CompressedLargeMessageControllerImpl.setBytes(int index,
HornetQBuffer src,
int srcIndex,
int length) |
void |
LargeMessageControllerImpl.writeBytes(HornetQBuffer src) |
void |
CompressedLargeMessageControllerImpl.writeBytes(HornetQBuffer src) |
void |
LargeMessageControllerImpl.writeBytes(HornetQBuffer src,
int length) |
void |
CompressedLargeMessageControllerImpl.writeBytes(HornetQBuffer src,
int length) |
void |
LargeMessageControllerImpl.writeBytes(HornetQBuffer src,
int srcIndex,
int length) |
void |
CompressedLargeMessageControllerImpl.writeBytes(HornetQBuffer src,
int srcIndex,
int length) |
Modifier and Type | Method and Description |
---|---|
void |
EncodingSupport.decode(HornetQBuffer buffer) |
void |
EncodingSupport.encode(HornetQBuffer buffer) |
void |
SequentialFile.write(HornetQBuffer bytes,
boolean sync) |
void |
SequentialFile.write(HornetQBuffer bytes,
boolean sync,
IOAsyncTask callback) |
Modifier and Type | Method and Description |
---|---|
protected HornetQBuffer |
AbstractJournalUpdateTask.getWritingChannel() |
Modifier and Type | Method and Description |
---|---|
void |
TimedBuffer.addBytes(HornetQBuffer bytes,
boolean sync,
IOAsyncTask callback) |
void |
AbstractSequentialFile.write(HornetQBuffer bytes,
boolean sync) |
void |
AbstractSequentialFile.write(HornetQBuffer bytes,
boolean sync,
IOAsyncTask callback) |
static void |
JournalImpl.writeHeader(HornetQBuffer buffer,
int userVersion,
long fileID) |
Modifier and Type | Method and Description |
---|---|
void |
JournalInternalRecord.decode(HornetQBuffer buffer) |
void |
ByteArrayEncoding.decode(HornetQBuffer buffer) |
void |
JournalRollbackRecordTX.encode(HornetQBuffer buffer) |
void |
JournalDeleteRecordTX.encode(HornetQBuffer buffer) |
void |
JournalDeleteRecord.encode(HornetQBuffer buffer) |
void |
JournalCompleteRecordTX.encode(HornetQBuffer buffer) |
void |
JournalAddRecordTX.encode(HornetQBuffer buffer) |
void |
JournalAddRecord.encode(HornetQBuffer buffer) |
void |
ByteArrayEncoding.encode(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
int |
BodyEncoder.encode(HornetQBuffer bufferOut,
int size)
This method must not be called directly by HornetQ clients.
|
Modifier and Type | Field and Description |
---|---|
protected HornetQBuffer |
MessageImpl.buffer |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
MessageImpl.getBodyBuffer() |
HornetQBuffer |
MessageInternal.getEncodedBuffer() |
HornetQBuffer |
MessageImpl.getEncodedBuffer() |
HornetQBuffer |
MessageInternal.getWholeBuffer() |
HornetQBuffer |
MessageImpl.getWholeBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
MessageImpl.decode(HornetQBuffer buff) |
void |
MessageInternal.decodeFromBuffer(HornetQBuffer buffer) |
void |
MessageImpl.decodeFromBuffer(HornetQBuffer buffer) |
void |
MessageInternal.decodeHeadersAndProperties(HornetQBuffer buffer) |
void |
MessageImpl.decodeHeadersAndProperties(HornetQBuffer buffer) |
void |
MessageImpl.encode(HornetQBuffer buff) |
void |
MessageInternal.encodeHeadersAndProperties(HornetQBuffer buffer) |
void |
MessageImpl.encodeHeadersAndProperties(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
PagedMessageImpl.decode(HornetQBuffer buffer) |
void |
PageTransactionInfoImpl.decode(HornetQBuffer buffer) |
void |
PagedMessageImpl.encode(HornetQBuffer buffer) |
void |
PageTransactionInfoImpl.encode(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
PersistedRoles.decode(HornetQBuffer buffer) |
void |
PersistedAddressSetting.decode(HornetQBuffer buffer) |
void |
PersistedRoles.encode(HornetQBuffer buffer) |
void |
PersistedAddressSetting.encode(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
LargeServerMessageImpl.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.XidEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.HeuristicCompletionEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.GroupingEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.PersistentQueueBindingEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.LargeMessageEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.PendingLargeMessageEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.DeliveryCountUpdateEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.QueueEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.DeleteEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.PageUpdateTXEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.ScheduledDeliveryEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.DuplicateIDEncoding.decode(HornetQBuffer buffer) |
void |
JournalStorageManager.CursorAckRecordEncoding.decode(HornetQBuffer buffer) |
void |
LargeServerMessageImpl.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.XidEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.HeuristicCompletionEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.GroupingEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.PersistentQueueBindingEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.LargeMessageEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.PendingLargeMessageEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.DeliveryCountUpdateEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.QueueEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.DeleteEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.PageUpdateTXEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.ScheduledDeliveryEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.DuplicateIDEncoding.encode(HornetQBuffer buffer) |
void |
JournalStorageManager.CursorAckRecordEncoding.encode(HornetQBuffer buffer) |
void |
LargeServerMessageImpl.encodeBody(HornetQBuffer bufferOut,
BodyEncoder context,
int size) |
void |
BatchingIDGenerator.loadState(long journalID,
HornetQBuffer buffer) |
protected static PersistedAddressSetting |
JournalStorageManager.newAddressEncoding(long id,
HornetQBuffer buffer) |
protected static JournalStorageManager.PersistentQueueBindingEncoding |
JournalStorageManager.newBindingEncoding(long id,
HornetQBuffer buffer) |
protected static JournalStorageManager.GroupingEncoding |
JournalStorageManager.newGroupEncoding(long id,
HornetQBuffer buffer) |
protected static PersistedRoles |
JournalStorageManager.newSecurityRecord(long id,
HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
Packet.encode(RemotingConnection connection)
Encodes the packet and returns a
HornetQBuffer containing the data |
Modifier and Type | Method and Description |
---|---|
void |
Packet.decode(HornetQBuffer buffer)
decodes the buffer into this packet
|
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
RemotingConnectionImpl.createBuffer(int size) |
HornetQBuffer |
PacketImpl.encode(RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
void |
RemotingConnectionImpl.bufferReceived(Object connectionID,
HornetQBuffer buffer) |
void |
PacketImpl.decode(HornetQBuffer buffer) |
Packet |
PacketDecoder.decode(HornetQBuffer in) |
void |
PacketImpl.decodeRest(HornetQBuffer buffer) |
void |
PacketImpl.encodeRest(HornetQBuffer buffer) |
void |
CoreProtocolManager.handleBuffer(RemotingConnection connection,
HornetQBuffer buffer) |
int |
CoreProtocolManager.isReadyToHandle(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
SessionSendMessage.encode(RemotingConnection connection) |
HornetQBuffer |
SessionReceiveMessage.encode(RemotingConnection connection) |
Modifier and Type | Method and Description |
---|---|
void |
SessionReceiveMessage.decode(HornetQBuffer buffer) |
void |
SubscribeClusterTopologyUpdatesMessageV2.decodeRest(HornetQBuffer buffer) |
void |
SubscribeClusterTopologyUpdatesMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAStartMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXASetTimeoutResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXASetTimeoutMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXARollbackMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAResumeMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAPrepareMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAJoinMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAGetTimeoutResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAGetInDoubtXidsResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAForgetMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXAEndMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionXACommitMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionSendMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionSendLargeMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionSendContinuationMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionRequestProducerCreditsMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionReceiveLargeMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionReceiveContinuationMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionQueueQueryResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionQueueQueryMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionProducerCreditsMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionIndividualAcknowledgeMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionForceConsumerDelivery.decodeRest(HornetQBuffer buffer) |
void |
SessionExpireMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionDeleteQueueMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionCreateConsumerMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionContinuationMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionConsumerFlowCreditMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionConsumerCloseMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionBindingQueryResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionBindingQueryMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionAddMetaDataMessageV2.decodeRest(HornetQBuffer buffer) |
void |
SessionAddMetaDataMessage.decodeRest(HornetQBuffer buffer) |
void |
SessionAcknowledgeMessage.decodeRest(HornetQBuffer buffer) |
void |
RollbackMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationPrepareMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationPageWriteMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationPageEventMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationLargemessageEndMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationLargeMessageWriteMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationLargeMessageBeingMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationDeleteTXMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationDeleteMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationCompareDataMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationCommitMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationAddTXMessage.decodeRest(HornetQBuffer buffer) |
void |
ReplicationAddMessage.decodeRest(HornetQBuffer buffer) |
void |
ReattachSessionResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
ReattachSessionMessage.decodeRest(HornetQBuffer buffer) |
void |
Ping.decodeRest(HornetQBuffer buffer) |
void |
PacketsConfirmedMessage.decodeRest(HornetQBuffer buffer) |
void |
NodeAnnounceMessage.decodeRest(HornetQBuffer buffer) |
void |
HornetQExceptionMessage.decodeRest(HornetQBuffer buffer) |
void |
DisconnectMessage.decodeRest(HornetQBuffer buffer) |
void |
CreateSessionResponseMessage.decodeRest(HornetQBuffer buffer) |
void |
CreateSessionMessage.decodeRest(HornetQBuffer buffer) |
void |
CreateReplicationSessionMessage.decodeRest(HornetQBuffer buffer) |
void |
CreateQueueMessage.decodeRest(HornetQBuffer buffer) |
void |
ClusterTopologyChangeMessage_V2.decodeRest(HornetQBuffer buffer) |
void |
ClusterTopologyChangeMessage.decodeRest(HornetQBuffer buffer) |
void |
SubscribeClusterTopologyUpdatesMessageV2.encodeRest(HornetQBuffer buffer) |
void |
SubscribeClusterTopologyUpdatesMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAStartMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXASetTimeoutResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXASetTimeoutMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXARollbackMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAResumeMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAPrepareMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAJoinMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAGetTimeoutResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAGetInDoubtXidsResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAForgetMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXAEndMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionXACommitMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionSendLargeMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionSendContinuationMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionRequestProducerCreditsMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionReceiveLargeMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionReceiveContinuationMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionQueueQueryResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionQueueQueryMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionProducerCreditsMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionIndividualAcknowledgeMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionForceConsumerDelivery.encodeRest(HornetQBuffer buffer) |
void |
SessionExpireMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionDeleteQueueMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionCreateConsumerMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionContinuationMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionConsumerFlowCreditMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionConsumerCloseMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionBindingQueryResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionBindingQueryMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionAddMetaDataMessageV2.encodeRest(HornetQBuffer buffer) |
void |
SessionAddMetaDataMessage.encodeRest(HornetQBuffer buffer) |
void |
SessionAcknowledgeMessage.encodeRest(HornetQBuffer buffer) |
void |
RollbackMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationPrepareMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationPageWriteMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationPageEventMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationLargemessageEndMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationLargeMessageWriteMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationLargeMessageBeingMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationDeleteTXMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationDeleteMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationCompareDataMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationCommitMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationAddTXMessage.encodeRest(HornetQBuffer buffer) |
void |
ReplicationAddMessage.encodeRest(HornetQBuffer buffer) |
void |
ReattachSessionResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
ReattachSessionMessage.encodeRest(HornetQBuffer buffer) |
void |
Ping.encodeRest(HornetQBuffer buffer) |
void |
PacketsConfirmedMessage.encodeRest(HornetQBuffer buffer) |
void |
NodeAnnounceMessage.encodeRest(HornetQBuffer buffer) |
void |
HornetQExceptionMessage.encodeRest(HornetQBuffer buffer) |
void |
DisconnectMessage.encodeRest(HornetQBuffer buffer) |
void |
CreateSessionResponseMessage.encodeRest(HornetQBuffer buffer) |
void |
CreateSessionMessage.encodeRest(HornetQBuffer buffer) |
void |
CreateReplicationSessionMessage.encodeRest(HornetQBuffer buffer) |
void |
CreateQueueMessage.encodeRest(HornetQBuffer buffer) |
void |
ClusterTopologyChangeMessage_V2.encodeRest(HornetQBuffer buffer) |
void |
ClusterTopologyChangeMessage.encodeRest(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
StompConnection.createBuffer(int size) |
Modifier and Type | Method and Description |
---|---|
void |
StompConnection.bufferReceived(Object connectionID,
HornetQBuffer buffer) |
org.hornetq.core.protocol.stomp.StompFrame |
StompDecoder.decode(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
InVMConnection.createBuffer(int size) |
Modifier and Type | Method and Description |
---|---|
void |
InVMConnection.write(HornetQBuffer buffer) |
void |
InVMConnection.write(HornetQBuffer buffer,
boolean flush,
boolean batch) |
Modifier and Type | Method and Description |
---|---|
HornetQBuffer |
NettyConnection.createBuffer(int size) |
Modifier and Type | Method and Description |
---|---|
void |
NettyConnection.write(HornetQBuffer buffer) |
void |
NettyConnection.write(HornetQBuffer buffer,
boolean flush,
boolean batched) |
Modifier and Type | Method and Description |
---|---|
void |
AddressSettings.decode(HornetQBuffer buffer) |
void |
AddressSettings.encode(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void |
PersistedJNDI.decode(HornetQBuffer buffer) |
void |
PersistedDestination.decode(HornetQBuffer buffer) |
void |
PersistedConnectionFactory.decode(HornetQBuffer buffer) |
void |
PersistedJNDI.encode(HornetQBuffer buffer) |
void |
PersistedDestination.encode(HornetQBuffer buffer) |
void |
PersistedConnectionFactory.encode(HornetQBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
static TransportConfiguration |
TransportConfigurationEncodingSupport.decode(HornetQBuffer buffer) |
void |
ConnectionFactoryConfigurationImpl.decode(HornetQBuffer buffer) |
static List<Pair<TransportConfiguration,TransportConfiguration>> |
TransportConfigurationEncodingSupport.decodeConfigs(HornetQBuffer buffer) |
void |
ConnectionFactoryConfigurationImpl.encode(HornetQBuffer buffer) |
static void |
TransportConfigurationEncodingSupport.encode(HornetQBuffer buffer,
TransportConfiguration config) |
static void |
TransportConfigurationEncodingSupport.encodeConfigs(HornetQBuffer buffer,
List<Pair<TransportConfiguration,TransportConfiguration>> configs) |
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(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.
|
Modifier and Type | Method and Description |
---|---|
void |
TypedProperties.decode(HornetQBuffer buffer) |
static Xid |
XidCodecSupport.decodeXid(HornetQBuffer in) |
void |
TypedProperties.encode(HornetQBuffer buffer) |
static void |
XidCodecSupport.encodeXid(Xid xid,
HornetQBuffer out) |
static Boolean |
BufferHelper.readNullableBoolean(HornetQBuffer buffer) |
static Integer |
BufferHelper.readNullableInteger(HornetQBuffer buffer) |
static Long |
BufferHelper.readNullableLong(HornetQBuffer buffer) |
static String |
BufferHelper.readNullableSimpleStringAsString(HornetQBuffer buffer) |
static String |
UTF8Util.readUTF(HornetQBuffer input) |
static void |
UTF8Util.saveUTF(HornetQBuffer out,
String str) |
static void |
BufferHelper.writeAsNullableSimpleString(HornetQBuffer buffer,
String str) |
static void |
BufferHelper.writeAsSimpleString(HornetQBuffer buffer,
String str) |
static void |
BufferHelper.writeNullableBoolean(HornetQBuffer buffer,
Boolean value) |
static void |
BufferHelper.writeNullableInteger(HornetQBuffer buffer,
Integer value) |
static void |
BufferHelper.writeNullableLong(HornetQBuffer buffer,
Long value) |
Constructor and Description |
---|
HornetQBufferInputStream(HornetQBuffer paramByteBuffer) |
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.