Uses of Interface
org.apache.activemq.artemis.api.core.ActiveMQBuffer

Packages that use ActiveMQBuffer

Package	Description
org.apache.activemq.artemis.api.core
org.apache.activemq.artemis.api.core.client
org.apache.activemq.artemis.core.buffers.impl
org.apache.activemq.artemis.core.client.impl
org.apache.activemq.artemis.core.io
org.apache.activemq.artemis.core.io.buffer
org.apache.activemq.artemis.core.journal
org.apache.activemq.artemis.core.journal.impl
org.apache.activemq.artemis.core.journal.impl.dataformat
org.apache.activemq.artemis.core.message
org.apache.activemq.artemis.core.message.impl
org.apache.activemq.artemis.core.paging.impl
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.config
org.apache.activemq.artemis.core.persistence.impl.journal
org.apache.activemq.artemis.core.persistence.impl.journal.codec
org.apache.activemq.artemis.core.protocol
org.apache.activemq.artemis.core.protocol.core
org.apache.activemq.artemis.core.protocol.core.impl
org.apache.activemq.artemis.core.protocol.core.impl.wireformat
org.apache.activemq.artemis.core.remoting.impl.invm
org.apache.activemq.artemis.core.remoting.impl.netty
org.apache.activemq.artemis.core.server.cluster.qourum
org.apache.activemq.artemis.core.server.impl
org.apache.activemq.artemis.core.settings.impl
org.apache.activemq.artemis.jdbc.store.file
org.apache.activemq.artemis.jms.persistence.config
org.apache.activemq.artemis.jms.server.config.impl
org.apache.activemq.artemis.reader
org.apache.activemq.artemis.spi.core.protocol
org.apache.activemq.artemis.spi.core.remoting
org.apache.activemq.artemis.utils

Uses of ActiveMQBuffer in org.apache.activemq.artemis.api.core

Methods in org.apache.activemq.artemis.api.core that return ActiveMQBuffer

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
default ActiveMQBuffer	Message.getBodyBuffer() Deprecated. do not use this, use through ICoreMessage or ClientMessage
ActiveMQBuffer	ICoreMessage.getBodyBuffer() The body used for this message.
ActiveMQBuffer	ICoreMessage.getDataBuffer() Returns a readOnlyBodyBuffer or a decompressed one if the message is compressed.
ActiveMQBuffer	ICoreMessage.getReadOnlyBodyBuffer() Returns a new Buffer slicing the current Body.
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(io.netty.buffer.ByteBuf underlying) Creates an ActiveMQBuffer wrapping an underlying ByteBuf The position on this buffer won't affect the position on the inner buffer
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

Methods in org.apache.activemq.artemis.api.core with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	TransportConfiguration.decode(ActiveMQBuffer buffer) Decodes this TransportConfiguration from a buffer.
void	TransportConfiguration.encode(ActiveMQBuffer buffer) Encodes this TransportConfiguration into a buffer.
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	Message.persist(ActiveMQBuffer targetRecord)
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	Message.reloadPersistence(ActiveMQBuffer record)
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).

Uses of ActiveMQBuffer in org.apache.activemq.artemis.api.core.client

Methods in org.apache.activemq.artemis.api.core.client that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	ClientMessage.getBodyBuffer() The buffer to write the body.

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.buffers.impl

Classes in org.apache.activemq.artemis.core.buffers.impl that implement ActiveMQBuffer

Modifier and Type	Class and Description
class	ChannelBufferWrapper
class	ResetLimitWrappedActiveMQBuffer A ResetLimitWrappedActiveMQBuffer

Methods in org.apache.activemq.artemis.core.buffers.impl that return ActiveMQBuffer

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)

Methods in org.apache.activemq.artemis.core.buffers.impl with parameters of type ActiveMQBuffer

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	ResetLimitWrappedActiveMQBuffer.setBytes(int index, ActiveMQBuffer src)
void	ChannelBufferWrapper.setBytes(int index, ActiveMQBuffer src, int length)
void	ResetLimitWrappedActiveMQBuffer.setBytes(int index, ActiveMQBuffer src, int length)
void	ChannelBufferWrapper.setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
void	ResetLimitWrappedActiveMQBuffer.setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
void	ChannelBufferWrapper.writeBytes(ActiveMQBuffer src, int length)
void	ResetLimitWrappedActiveMQBuffer.writeBytes(ActiveMQBuffer src, int length)
void	ChannelBufferWrapper.writeBytes(ActiveMQBuffer src, int srcIndex, int length)
void	ResetLimitWrappedActiveMQBuffer.writeBytes(ActiveMQBuffer src, int srcIndex, int length)

Constructors in org.apache.activemq.artemis.core.buffers.impl with parameters of type ActiveMQBuffer

Constructor and Description
ResetLimitWrappedActiveMQBuffer(int limit, ActiveMQBuffer buffer, Message message)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.client.impl

Subinterfaces of ActiveMQBuffer in org.apache.activemq.artemis.core.client.impl

Modifier and Type	Interface and Description
interface	LargeMessageController

Classes in org.apache.activemq.artemis.core.client.impl that implement ActiveMQBuffer

Modifier and Type	Class and Description
class	LargeMessageControllerImpl This class aggregates several SessionReceiveContinuationMessage as it was being handled by a single buffer.

Methods in org.apache.activemq.artemis.core.client.impl that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	LargeMessageControllerImpl.copy()
ActiveMQBuffer	LargeMessageControllerImpl.copy(int index, int length)
ActiveMQBuffer	LargeMessageControllerImpl.duplicate()
ActiveMQBuffer	ClientLargeMessageImpl.getBodyBuffer()
ActiveMQBuffer	LargeMessageControllerImpl.readBytes(int length)
ActiveMQBuffer	LargeMessageControllerImpl.readSlice(int length)
ActiveMQBuffer	LargeMessageControllerImpl.slice()
ActiveMQBuffer	LargeMessageControllerImpl.slice(int index, int length)

Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	LargeMessageControllerImpl.getBytes(int index, ActiveMQBuffer dst)
void	LargeMessageControllerImpl.getBytes(int index, ActiveMQBuffer dst, int length)
void	LargeMessageControllerImpl.getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)
void	LargeMessageControllerImpl.readBytes(ActiveMQBuffer dst)
void	LargeMessageControllerImpl.readBytes(ActiveMQBuffer dst, int length)
void	LargeMessageControllerImpl.readBytes(ActiveMQBuffer dst, int dstIndex, int length)
void	LargeMessageControllerImpl.setBytes(int index, ActiveMQBuffer src)
void	LargeMessageControllerImpl.setBytes(int index, ActiveMQBuffer src, int length)
void	LargeMessageControllerImpl.setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
void	LargeMessageControllerImpl.writeBytes(ActiveMQBuffer src)
void	LargeMessageControllerImpl.writeBytes(ActiveMQBuffer src, int length)
void	LargeMessageControllerImpl.writeBytes(ActiveMQBuffer src, int srcIndex, int length)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.io

Methods in org.apache.activemq.artemis.core.io with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	SequentialFile.write(ActiveMQBuffer bytes, boolean sync)
void	AbstractSequentialFile.write(ActiveMQBuffer bytes, boolean sync)
void	SequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	AbstractSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.io.buffer

Methods in org.apache.activemq.artemis.core.io.buffer with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	TimedBuffer.addBytes(ActiveMQBuffer bytes, boolean sync, IOCallback callback)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.journal

Methods in org.apache.activemq.artemis.core.journal with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	EncodingSupport.decode(ActiveMQBuffer buffer)
EncodingSupport	EncoderPersister.decode(ActiveMQBuffer buffer, EncodingSupport record)
void	EncodingSupport.encode(ActiveMQBuffer buffer)
void	EncoderPersister.encode(ActiveMQBuffer buffer, EncodingSupport record)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.journal.impl

Methods in org.apache.activemq.artemis.core.journal.impl that return ActiveMQBuffer

Modifier and Type	Method and Description
protected ActiveMQBuffer	AbstractJournalUpdateTask.getWritingChannel()

Methods in org.apache.activemq.artemis.core.journal.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
static void	JournalImpl.writeHeader(ActiveMQBuffer buffer, int userVersion, long fileID)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.journal.impl.dataformat

Methods in org.apache.activemq.artemis.core.journal.impl.dataformat with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	JournalInternalRecord.decode(ActiveMQBuffer buffer)
void	ByteArrayEncoding.decode(ActiveMQBuffer buffer)
void	JournalRollbackRecordTX.encode(ActiveMQBuffer buffer)
void	JournalDeleteRecordTX.encode(ActiveMQBuffer buffer)
void	JournalDeleteRecord.encode(ActiveMQBuffer buffer)
void	JournalCompleteRecordTX.encode(ActiveMQBuffer buffer)
void	JournalAddRecordTX.encode(ActiveMQBuffer buffer)
void	JournalAddRecord.encode(ActiveMQBuffer buffer)
void	ByteArrayEncoding.encode(ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.message

Methods in org.apache.activemq.artemis.core.message with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
int	LargeBodyEncoder.encode(ActiveMQBuffer bufferOut, int size) This method must not be called directly by ActiveMQ Artemis clients.
int	BodyEncoder.encode(ActiveMQBuffer bufferOut, int size) Deprecated. This method must not be called directly by ActiveMQ Artemis clients.

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.message.impl

Methods in org.apache.activemq.artemis.core.message.impl that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	CoreMessage.getBodyBuffer() The body used for this message.
ActiveMQBuffer	CoreMessage.getDataBuffer() This will return the proper buffer to represent the data of the Message.
ActiveMQBuffer	MessageInternalImpl.getEncodedBuffer() Deprecated.
ActiveMQBuffer	MessageInternal.getEncodedBuffer() Deprecated.
ActiveMQBuffer	CoreMessage.getReadOnlyBodyBuffer()
ActiveMQBuffer	MessageInternalImpl.getWholeBuffer() Deprecated.
ActiveMQBuffer	MessageInternal.getWholeBuffer() Deprecated.

Methods in org.apache.activemq.artemis.core.message.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
Message	CoreMessagePersister.decode(ActiveMQBuffer buffer, Message record)
void	MessageInternalImpl.decodeFromBuffer(ActiveMQBuffer buffer) Deprecated.
void	MessageInternal.decodeFromBuffer(ActiveMQBuffer buffer) Deprecated.
void	MessageInternalImpl.decodeHeadersAndProperties(ActiveMQBuffer buffer) Deprecated.
void	MessageInternal.decodeHeadersAndProperties(ActiveMQBuffer buffer) Deprecated.
void	CoreMessagePersister.encode(ActiveMQBuffer buffer, Message record) Sub classes must add the first short as the protocol-id
void	MessageInternalImpl.encodeHeadersAndProperties(ActiveMQBuffer buffer) Deprecated.
void	MessageInternal.encodeHeadersAndProperties(ActiveMQBuffer buffer) Deprecated.
void	MessageInternalImpl.persist(ActiveMQBuffer targetRecord) Deprecated.
void	CoreMessage.persist(ActiveMQBuffer targetRecord)
void	MessageInternalImpl.reloadPersistence(ActiveMQBuffer record) Deprecated.
void	CoreMessage.reloadPersistence(ActiveMQBuffer record)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.paging.impl

Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	PagedMessageImpl.decode(ActiveMQBuffer buffer)
void	PageTransactionInfoImpl.decode(ActiveMQBuffer buffer)
void	PagedMessageImpl.encode(ActiveMQBuffer buffer)
void	PageTransactionInfoImpl.encode(ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.persistence

Methods in org.apache.activemq.artemis.core.persistence with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
T	Persister.decode(ActiveMQBuffer buffer, T record)
void	Persister.encode(ActiveMQBuffer buffer, T record)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.persistence.config

Methods in org.apache.activemq.artemis.core.persistence.config with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	PersistedRoles.decode(ActiveMQBuffer buffer)
void	PersistedAddressSetting.decode(ActiveMQBuffer buffer)
void	PersistedRoles.encode(ActiveMQBuffer buffer)
void	PersistedAddressSetting.encode(ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.persistence.impl.journal

Methods in org.apache.activemq.artemis.core.persistence.impl.journal that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	LargeServerMessageImpl.getReadOnlyBodyBuffer()

Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	LargeServerMessageImpl.decode(ActiveMQBuffer buffer1)
void	BatchingIDGenerator.IDCounterEncoding.decode(ActiveMQBuffer buffer)
void	LargeServerMessageImpl.encode(ActiveMQBuffer buffer1)
void	BatchingIDGenerator.IDCounterEncoding.encode(ActiveMQBuffer buffer)
void	BatchingIDGenerator.loadState(long journalID, ActiveMQBuffer buffer)
protected static PersistentAddressBindingEncoding	AbstractJournalStorageManager.newAddressBindingEncoding(long id, ActiveMQBuffer buffer)
protected static PersistentQueueBindingEncoding	AbstractJournalStorageManager.newQueueBindingEncoding(long id, ActiveMQBuffer buffer)
protected static QueueStatusEncoding	AbstractJournalStorageManager.newQueueStatusEncoding(long id, ActiveMQBuffer buffer)
protected static PersistedRoles	AbstractJournalStorageManager.newSecurityRecord(long id, ActiveMQBuffer buffer)
protected LargeServerMessage	JournalStorageManager.parseLargeMessage(Map<Long,Message> messages, ActiveMQBuffer buff)
protected abstract LargeServerMessage	AbstractJournalStorageManager.parseLargeMessage(Map<Long,Message> messages, ActiveMQBuffer buff)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.persistence.impl.journal.codec

Methods in org.apache.activemq.artemis.core.persistence.impl.journal.codec with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	XidEncoding.decode(ActiveMQBuffer buffer)
void	ScheduledDeliveryEncoding.decode(ActiveMQBuffer buffer)
void	QueueStatusEncoding.decode(ActiveMQBuffer buffer)
void	QueueEncoding.decode(ActiveMQBuffer buffer)
void	PersistentQueueBindingEncoding.decode(ActiveMQBuffer buffer)
void	PersistentAddressBindingEncoding.decode(ActiveMQBuffer buffer)
void	PendingLargeMessageEncoding.decode(ActiveMQBuffer buffer)
void	PageUpdateTXEncoding.decode(ActiveMQBuffer buffer)
void	PageCountRecordInc.decode(ActiveMQBuffer buffer)
void	PageCountRecord.decode(ActiveMQBuffer buffer)
void	PageCountPendingImpl.decode(ActiveMQBuffer buffer)
void	HeuristicCompletionEncoding.decode(ActiveMQBuffer buffer)
void	GroupingEncoding.decode(ActiveMQBuffer buffer)
void	DuplicateIDEncoding.decode(ActiveMQBuffer buffer)
void	DeliveryCountUpdateEncoding.decode(ActiveMQBuffer buffer)
void	DeleteEncoding.decode(ActiveMQBuffer buffer)
void	CursorAckRecordEncoding.decode(ActiveMQBuffer buffer)
LargeServerMessage	LargeMessagePersister.decode(ActiveMQBuffer buffer, LargeServerMessage message)
void	XidEncoding.encode(ActiveMQBuffer buffer)
void	ScheduledDeliveryEncoding.encode(ActiveMQBuffer buffer)
void	QueueStatusEncoding.encode(ActiveMQBuffer buffer)
void	QueueEncoding.encode(ActiveMQBuffer buffer)
void	PersistentQueueBindingEncoding.encode(ActiveMQBuffer buffer)
void	PersistentAddressBindingEncoding.encode(ActiveMQBuffer buffer)
void	PendingLargeMessageEncoding.encode(ActiveMQBuffer buffer)
void	PageUpdateTXEncoding.encode(ActiveMQBuffer buffer)
void	PageCountRecordInc.encode(ActiveMQBuffer buffer)
void	PageCountRecord.encode(ActiveMQBuffer buffer)
void	PageCountPendingImpl.encode(ActiveMQBuffer buffer)
void	HeuristicCompletionEncoding.encode(ActiveMQBuffer buffer)
void	GroupingEncoding.encode(ActiveMQBuffer buffer)
void	DuplicateIDEncoding.encode(ActiveMQBuffer buffer)
void	DeliveryCountUpdateEncoding.encode(ActiveMQBuffer buffer)
void	DeleteEncoding.encode(ActiveMQBuffer buffer)
void	CursorAckRecordEncoding.encode(ActiveMQBuffer buffer)
void	LargeMessagePersister.encode(ActiveMQBuffer buffer, LargeServerMessage message)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.protocol

Methods in org.apache.activemq.artemis.core.protocol with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
Packet	ServerPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)
Packet	ClientPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.protocol.core

Methods in org.apache.activemq.artemis.core.protocol.core that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	Packet.encode(CoreRemotingConnection connection) Encodes the packet and returns a ActiveMQBuffer containing the data

Methods in org.apache.activemq.artemis.core.protocol.core with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	Packet.decode(ActiveMQBuffer buffer) decodes the buffer into this packet

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.protocol.core.impl

Methods in org.apache.activemq.artemis.core.protocol.core.impl that return ActiveMQBuffer

Modifier and Type	Method and Description
protected ActiveMQBuffer	PacketImpl.createPacket(CoreRemotingConnection connection)
ActiveMQBuffer	PacketImpl.encode(CoreRemotingConnection connection)

Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	RemotingConnectionImpl.bufferReceived(Object connectionID, ActiveMQBuffer buffer)
void	PacketImpl.decode(ActiveMQBuffer buffer)
abstract Packet	PacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)
void	PacketImpl.decodeRest(ActiveMQBuffer buffer)
protected void	PacketImpl.encodeHeader(ActiveMQBuffer buffer)
void	PacketImpl.encodeRest(ActiveMQBuffer buffer)
protected void	PacketImpl.encodeSize(ActiveMQBuffer buffer)
void	CoreProtocolManager.handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
void	CoreProtocolManager.handshake(NettyServerConnection connection, ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	ScaleDownAnnounceMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationSyncFileMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationStartSyncMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationResponseMessageV2.decodeRest(ActiveMQBuffer buffer)
void	ReplicationPrepareMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationPageWriteMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationPageEventMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationLiveIsStoppingMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageWriteMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageEndMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageBeginMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteTXMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationCommitMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationAddTXMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationAddMessage.decodeRest(ActiveMQBuffer buffer)
void	QuorumVoteReplyMessage.decodeRest(ActiveMQBuffer buffer)
void	QuorumVoteMessage.decodeRest(ActiveMQBuffer buffer)
void	NodeAnnounceMessage.decodeRest(ActiveMQBuffer buffer)
void	ClusterConnectReplyMessage.decodeRest(ActiveMQBuffer buffer)
void	ClusterConnectMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupRequestMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupReplicationStartFailedMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupRegistrationMessage.decodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessageV2.decodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAStartMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXARollbackMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAResumeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAPrepareMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAJoinMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAGetTimeoutResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAGetInDoubtXidsResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAForgetMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAEndMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXACommitMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAAfterFailedMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionSendLargeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionRequestProducerCreditsMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveLargeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveContinuationMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveClientLargeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsFailMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionIndividualAcknowledgeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionForceConsumerDelivery.decodeRest(ActiveMQBuffer buffer)
void	SessionExpireMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionDeleteQueueMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionCreateConsumerMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionContinuationMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionConsumerFlowCreditMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionConsumerCloseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V4.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessageV2.decodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionAcknowledgeMessage.decodeRest(ActiveMQBuffer buffer)
void	RollbackMessage.decodeRest(ActiveMQBuffer buffer)
void	ReattachSessionResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	ReattachSessionMessage.decodeRest(ActiveMQBuffer buffer)
void	Ping.decodeRest(ActiveMQBuffer buffer)
void	PacketsConfirmedMessage.decodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage.decodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerWithKillMessage.decodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateSessionResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateSessionMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateAddressMessage.decodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage.decodeRest(ActiveMQBuffer buffer)
void	CheckFailoverReplyMessage.decodeRest(ActiveMQBuffer buffer)
void	CheckFailoverMessage.decodeRest(ActiveMQBuffer buffer)
void	ActiveMQExceptionMessage.decodeRest(ActiveMQBuffer buffer)
void	ScaleDownAnnounceMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationSyncFileMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationStartSyncMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationResponseMessageV2.encodeRest(ActiveMQBuffer buffer)
void	ReplicationPrepareMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationPageWriteMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationPageEventMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationLiveIsStoppingMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageWriteMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageEndMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageBeginMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteTXMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationCommitMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationAddTXMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationAddMessage.encodeRest(ActiveMQBuffer buffer)
void	QuorumVoteReplyMessage.encodeRest(ActiveMQBuffer buffer)
void	QuorumVoteMessage.encodeRest(ActiveMQBuffer buffer)
void	NodeAnnounceMessage.encodeRest(ActiveMQBuffer buffer)
void	ClusterConnectReplyMessage.encodeRest(ActiveMQBuffer buffer)
void	ClusterConnectMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupRequestMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupReplicationStartFailedMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupRegistrationMessage.encodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessageV2.encodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAStartMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXARollbackMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAResumeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAPrepareMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAJoinMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAGetTimeoutResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAGetInDoubtXidsResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAForgetMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAEndMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXACommitMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAAfterFailedMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage_1X.encodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionSendLargeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionRequestProducerCreditsMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveMessage_1X.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveLargeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveContinuationMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsFailMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionIndividualAcknowledgeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionForceConsumerDelivery.encodeRest(ActiveMQBuffer buffer)
void	SessionExpireMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionDeleteQueueMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionCreateConsumerMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionContinuationMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionConsumerFlowCreditMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionConsumerCloseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V4.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessageV2.encodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionAcknowledgeMessage.encodeRest(ActiveMQBuffer buffer)
void	RollbackMessage.encodeRest(ActiveMQBuffer buffer)
void	ReattachSessionResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	ReattachSessionMessage.encodeRest(ActiveMQBuffer buffer)
void	Ping.encodeRest(ActiveMQBuffer buffer)
void	PacketsConfirmedMessage.encodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage.encodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerWithKillMessage.encodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateSessionResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateSessionMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateAddressMessage.encodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage.encodeRest(ActiveMQBuffer buffer)
void	CheckFailoverReplyMessage.encodeRest(ActiveMQBuffer buffer)
void	CheckFailoverMessage.encodeRest(ActiveMQBuffer buffer)
void	ActiveMQExceptionMessage.encodeRest(ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.remoting.impl.invm

Methods in org.apache.activemq.artemis.core.remoting.impl.invm that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	InVMConnection.createTransportBuffer(int size)

Methods in org.apache.activemq.artemis.core.remoting.impl.invm with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	InVMConnection.write(ActiveMQBuffer buffer)
void	InVMConnection.write(ActiveMQBuffer buffer, boolean flush, boolean batch)
void	InVMConnection.write(ActiveMQBuffer buffer, boolean flush, boolean batch, io.netty.channel.ChannelFutureListener futureListener)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.remoting.impl.netty

Methods in org.apache.activemq.artemis.core.remoting.impl.netty that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	NettyConnection.createTransportBuffer(int size)

Methods in org.apache.activemq.artemis.core.remoting.impl.netty with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	NettyConnection.write(ActiveMQBuffer buffer)
void	NettyConnection.write(ActiveMQBuffer buffer, boolean flush, boolean batched)
void	NettyConnection.write(ActiveMQBuffer buffer, boolean flush, boolean batched, io.netty.channel.ChannelFutureListener futureListener)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.server.cluster.qourum

Methods in org.apache.activemq.artemis.core.server.cluster.qourum with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
abstract void	Vote.decode(ActiveMQBuffer buff)
void	ServerConnectVote.decode(ActiveMQBuffer buff)
Vote	QuorumVoteHandler.decode(ActiveMQBuffer voteBuffer)
void	BooleanVote.decode(ActiveMQBuffer buff)
abstract void	Vote.encode(ActiveMQBuffer buff)
void	ServerConnectVote.encode(ActiveMQBuffer buff)
void	BooleanVote.encode(ActiveMQBuffer buff)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.server.impl

Methods in org.apache.activemq.artemis.core.server.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
Vote	ServerConnectVoteHandler.decode(ActiveMQBuffer voteBuffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.core.settings.impl

Methods in org.apache.activemq.artemis.core.settings.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	ResourceLimitSettings.decode(ActiveMQBuffer buffer)
void	AddressSettings.decode(ActiveMQBuffer buffer)
void	AddressSettings.decode(ActiveMQBuffer buffer, boolean tryCompatible)
void	ResourceLimitSettings.encode(ActiveMQBuffer buffer)
void	AddressSettings.encode(ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.jdbc.store.file

Methods in org.apache.activemq.artemis.jdbc.store.file with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
int	JDBCSequentialFile.internalWrite(ActiveMQBuffer buffer, IOCallback callback)
void	JDBCSequentialFile.write(ActiveMQBuffer bytes, boolean sync)
void	JDBCSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.jms.persistence.config

Methods in org.apache.activemq.artemis.jms.persistence.config with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	PersistedDestination.decode(ActiveMQBuffer buffer)
void	PersistedConnectionFactory.decode(ActiveMQBuffer buffer)
void	PersistedBindings.decode(ActiveMQBuffer buffer)
void	PersistedDestination.encode(ActiveMQBuffer buffer)
void	PersistedConnectionFactory.encode(ActiveMQBuffer buffer)
void	PersistedBindings.encode(ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.jms.server.config.impl

Methods in org.apache.activemq.artemis.jms.server.config.impl with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
static TransportConfiguration	TransportConfigurationEncodingSupport.decode(ActiveMQBuffer buffer)
void	ConnectionFactoryConfigurationImpl.decode(ActiveMQBuffer buffer)
static List<Pair<TransportConfiguration,TransportConfiguration>>	TransportConfigurationEncodingSupport.decodeConfigs(ActiveMQBuffer buffer)
void	ConnectionFactoryConfigurationImpl.encode(ActiveMQBuffer buffer)
static void	TransportConfigurationEncodingSupport.encode(ActiveMQBuffer buffer, TransportConfiguration config)
static void	TransportConfigurationEncodingSupport.encodeConfigs(ActiveMQBuffer buffer, List<Pair<TransportConfiguration,TransportConfiguration>> configs)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.reader

Methods in org.apache.activemq.artemis.reader with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
static void	BytesMessageUtil.bytesMessageReset(ActiveMQBuffer message)
static boolean	BytesMessageUtil.bytesReadBoolean(ActiveMQBuffer message)
static byte	BytesMessageUtil.bytesReadByte(ActiveMQBuffer message)
static int	BytesMessageUtil.bytesReadBytes(ActiveMQBuffer message, byte[] value)
static int	BytesMessageUtil.bytesReadBytes(ActiveMQBuffer message, byte[] value, int length)
static char	BytesMessageUtil.bytesReadChar(ActiveMQBuffer message)
static double	BytesMessageUtil.bytesReadDouble(ActiveMQBuffer message)
static float	BytesMessageUtil.bytesReadFloat(ActiveMQBuffer message)
static int	BytesMessageUtil.bytesReadInt(ActiveMQBuffer message)
static long	BytesMessageUtil.bytesReadLong(ActiveMQBuffer message)
static short	BytesMessageUtil.bytesReadShort(ActiveMQBuffer message)
static int	BytesMessageUtil.bytesReadUnsignedByte(ActiveMQBuffer message)
static int	BytesMessageUtil.bytesReadUnsignedShort(ActiveMQBuffer message)
static String	BytesMessageUtil.bytesReadUTF(ActiveMQBuffer message)
static void	BytesMessageUtil.bytesWriteBoolean(ActiveMQBuffer message, boolean value)
static void	BytesMessageUtil.bytesWriteByte(ActiveMQBuffer message, byte value)
static void	BytesMessageUtil.bytesWriteBytes(ActiveMQBuffer message, byte[] value)
static void	BytesMessageUtil.bytesWriteBytes(ActiveMQBuffer message, byte[] value, int offset, int length)
static void	BytesMessageUtil.bytesWriteChar(ActiveMQBuffer message, char value)
static void	BytesMessageUtil.bytesWriteDouble(ActiveMQBuffer message, double value)
static void	BytesMessageUtil.bytesWriteFloat(ActiveMQBuffer message, float value)
static void	BytesMessageUtil.bytesWriteInt(ActiveMQBuffer message, int value)
static void	BytesMessageUtil.bytesWriteLong(ActiveMQBuffer message, long value)
static boolean	BytesMessageUtil.bytesWriteObject(ActiveMQBuffer message, Object value) Returns true if it could send the Object to any known format
static void	BytesMessageUtil.bytesWriteShort(ActiveMQBuffer message, short value)
static void	BytesMessageUtil.bytesWriteUTF(ActiveMQBuffer message, String value)
static TypedProperties	MapMessageUtil.readBodyMap(ActiveMQBuffer message) Utility method to set the map on a message body
static void	MapMessageUtil.readBodyMap(ActiveMQBuffer message, TypedProperties map) Utility method to set the map on a message body
static SimpleString	TextMessageUtil.readBodyText(ActiveMQBuffer buff) Utility method to set the Text message on a message body
static boolean	StreamMessageUtil.streamReadBoolean(ActiveMQBuffer buff) Method to read boolean values out of the Stream protocol existent on JMS Stream Messages Throws IllegalStateException if the type was invalid
static byte	StreamMessageUtil.streamReadByte(ActiveMQBuffer buff)
static Pair<Integer,Integer>	StreamMessageUtil.streamReadBytes(ActiveMQBuffer buff, int remainingBytes, byte[] value) Utility for reading bytes out of streaming.
static char	StreamMessageUtil.streamReadChar(ActiveMQBuffer buff)
static double	StreamMessageUtil.streamReadDouble(ActiveMQBuffer buff)
static float	StreamMessageUtil.streamReadFloat(ActiveMQBuffer buff)
static int	StreamMessageUtil.streamReadInteger(ActiveMQBuffer buff)
static long	StreamMessageUtil.streamReadLong(ActiveMQBuffer buff)
static Object	StreamMessageUtil.streamReadObject(ActiveMQBuffer buff)
static short	StreamMessageUtil.streamReadShort(ActiveMQBuffer buff)
static String	StreamMessageUtil.streamReadString(ActiveMQBuffer buff)
static void	MapMessageUtil.writeBodyMap(ActiveMQBuffer message, TypedProperties properties) Utility method to set the map on a message body
static void	TextMessageUtil.writeBodyText(ActiveMQBuffer buff, SimpleString text) Utility method to set the Text message on a message body

Uses of ActiveMQBuffer in org.apache.activemq.artemis.spi.core.protocol

Methods in org.apache.activemq.artemis.spi.core.protocol that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	RemotingConnection.createTransportBuffer(int size) creates a new ActiveMQBuffer of the specified size.
ActiveMQBuffer	AbstractRemotingConnection.createTransportBuffer(int size)

Methods in org.apache.activemq.artemis.spi.core.protocol with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	AbstractRemotingConnection.bufferReceived(Object connectionID, ActiveMQBuffer buffer)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record)
void	MessagePersister.encode(ActiveMQBuffer buffer, Message record) Sub classes must add the first short as the protocol-id
void	ProtocolManager.handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)
void	ProtocolManager.handshake(NettyServerConnection connection, ActiveMQBuffer buffer)

Uses of ActiveMQBuffer in org.apache.activemq.artemis.spi.core.remoting

Methods in org.apache.activemq.artemis.spi.core.remoting that return ActiveMQBuffer

Modifier and Type	Method and Description
ActiveMQBuffer	Connection.createTransportBuffer(int size) Create a new ActiveMQBuffer of the given size.

Methods in org.apache.activemq.artemis.spi.core.remoting with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
void	BufferHandler.bufferReceived(Object connectionID, ActiveMQBuffer buffer) called by the remoting connection when a buffer is received.
int	BufferDecoder.isReadyToHandle(ActiveMQBuffer buffer) called by the remoting system prior to BufferHandler.bufferReceived(Object, ActiveMQBuffer).
void	Connection.write(ActiveMQBuffer buffer) writes the buffer to the connection with no flushing or batching
void	Connection.write(ActiveMQBuffer 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.
void	Connection.write(ActiveMQBuffer buffer, boolean flush, boolean batched, io.netty.channel.ChannelFutureListener futureListener) writes the buffer to the connection and if flush is true returns only when the buffer has been physically written to the connection.

Uses of ActiveMQBuffer in org.apache.activemq.artemis.utils

Methods in org.apache.activemq.artemis.utils that return ActiveMQBuffer

Modifier and Type	Method and Description
static ActiveMQBuffer	RandomUtil.randomBuffer(int size, long... data)

Methods in org.apache.activemq.artemis.utils with parameters of type ActiveMQBuffer

Modifier and Type	Method and Description
static Xid	XidCodecSupport.decodeXid(ActiveMQBuffer in)
static void	XidCodecSupport.encodeXid(Xid xid, ActiveMQBuffer out)
static String	ByteUtil.readLine(ActiveMQBuffer buffer)
static Boolean	BufferHelper.readNullableBoolean(ActiveMQBuffer buffer)
static Double	BufferHelper.readNullableDouble(ActiveMQBuffer buffer)
static Integer	BufferHelper.readNullableInteger(ActiveMQBuffer buffer)
static Long	BufferHelper.readNullableLong(ActiveMQBuffer buffer)
static String	BufferHelper.readNullableSimpleStringAsString(ActiveMQBuffer buffer)
static String	UTF8Util.readUTF(ActiveMQBuffer input)
static void	BufferHelper.writeAsNullableSimpleString(ActiveMQBuffer buffer, String str)
static void	BufferHelper.writeAsSimpleString(ActiveMQBuffer buffer, String str)
static void	BufferHelper.writeNullableBoolean(ActiveMQBuffer buffer, Boolean value)
static void	BufferHelper.writeNullableDouble(ActiveMQBuffer buffer, Double value)
static void	BufferHelper.writeNullableInteger(ActiveMQBuffer buffer, Integer value)
static void	BufferHelper.writeNullableLong(ActiveMQBuffer buffer, Long value)

Constructors in org.apache.activemq.artemis.utils with parameters of type ActiveMQBuffer

Constructor and Description
ActiveMQBufferInputStream(ActiveMQBuffer paramByteBuffer)