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.config
org.apache.activemq.artemis.core.config.federation
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.collections
org.apache.activemq.artemis.core.journal.impl
org.apache.activemq.artemis.core.journal.impl.dataformat
org.apache.activemq.artemis.core.management.impl
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.persistence.impl.nullpm
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
org.apache.activemq.artemis.core.server.cluster.quorum
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	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
ActiveMQBuffer	ICoreMessage.getBodyBuffer()	The buffer to write the body.
default ActiveMQBuffer	Message.getBodyBuffer()	Deprecated. do not use this, use through ICoreMessage or ClientMessage Warning: if you need to read the content of a message use getDataBuffer().
ActiveMQBuffer	ICoreMessage.getDataBuffer()	Returns a readOnlyBodyBuffer or a decompressed one if the message is compressed or the large message buffer.
ActiveMQBuffer	ICoreMessage.getReadOnlyBodyBuffer()	Returns a new Buffer slicing the current Body.
static ActiveMQBuffer	ActiveMQBuffers.pooledBuffer(int size)
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
static ActiveMQBuffer	ActiveMQBuffers.wrappedBuffer(ByteBuffer underlying)	Creates an ActiveMQBuffer wrapping an underlying NIO ByteBuffer

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

Modifier and Type	Method	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, CoreMessageObjectPools pools)
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	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	Description
class	ChannelBufferWrapper
final class	ResetLimitWrappedActiveMQBuffer	A ResetLimitWrappedActiveMQBuffer

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

Modifier and Type	Method	Description
ActiveMQBuffer	ChannelBufferWrapper.copy()
ActiveMQBuffer	ChannelBufferWrapper.copy(int index, int length)
ActiveMQBuffer	ChannelBufferWrapper.duplicate()
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	Description
void	ChannelBufferWrapper.getBytes(int index, ActiveMQBuffer dst)
void	ChannelBufferWrapper.getBytes(int index, ActiveMQBuffer dst, int length)
void	ChannelBufferWrapper.getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)
void	ChannelBufferWrapper.readBytes(ActiveMQBuffer dst)
void	ChannelBufferWrapper.readBytes(ActiveMQBuffer dst, int length)
void	ChannelBufferWrapper.readBytes(ActiveMQBuffer dst, int dstIndex, int length)
void	ChannelBufferWrapper.setBytes(int index, ActiveMQBuffer src)
void	ChannelBufferWrapper.setBytes(int index, ActiveMQBuffer src, int length)
void	ChannelBufferWrapper.setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
void	ResetLimitWrappedActiveMQBuffer.setBytes(int index, ActiveMQBuffer src)
void	ResetLimitWrappedActiveMQBuffer.setBytes(int index, ActiveMQBuffer src, int length)
void	ResetLimitWrappedActiveMQBuffer.setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
void	ChannelBufferWrapper.writeBytes(ActiveMQBuffer src, int length)
void	ChannelBufferWrapper.writeBytes(ActiveMQBuffer src, int srcIndex, int length)
void	ResetLimitWrappedActiveMQBuffer.writeBytes(ActiveMQBuffer src, 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

Modifier	Constructor	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	Description
interface	LargeMessageController

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

Modifier and Type	Class	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	Description
ActiveMQBuffer	LargeMessageControllerImpl.copy()
ActiveMQBuffer	LargeMessageControllerImpl.copy(int index, int length)
ActiveMQBuffer	LargeMessageControllerImpl.duplicate()
ActiveMQBuffer	ClientLargeMessageImpl.getBodyBuffer()
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	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.config

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

Modifier and Type	Method	Description
void	BridgeConfiguration.decode(ActiveMQBuffer buffer)
void	DivertConfiguration.decode(ActiveMQBuffer buffer)
void	FederationConfiguration.Credentials.decode(ActiveMQBuffer buffer)
void	BridgeConfiguration.encode(ActiveMQBuffer buffer)
void	DivertConfiguration.encode(ActiveMQBuffer buffer)
void	FederationConfiguration.Credentials.encode(ActiveMQBuffer buffer)

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

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

Modifier and Type	Method	Description
void	FederationAddressPolicyConfiguration.decode(ActiveMQBuffer buffer)
void	FederationAddressPolicyConfiguration.Matcher.decode(ActiveMQBuffer buffer)
void	FederationConnectionConfiguration.decode(ActiveMQBuffer buffer)
void	FederationDownstreamConfiguration.decode(ActiveMQBuffer buffer)
void	FederationPolicy.decode(ActiveMQBuffer buffer)
void	FederationPolicySet.decode(ActiveMQBuffer buffer)
void	FederationQueuePolicyConfiguration.decode(ActiveMQBuffer buffer)
void	FederationQueuePolicyConfiguration.Matcher.decode(ActiveMQBuffer buffer)
void	FederationStreamConfiguration.decode(ActiveMQBuffer buffer)
void	FederationTransformerConfiguration.decode(ActiveMQBuffer buffer)
void	FederationAddressPolicyConfiguration.encode(ActiveMQBuffer buffer)
void	FederationAddressPolicyConfiguration.Matcher.encode(ActiveMQBuffer buffer)
void	FederationConnectionConfiguration.encode(ActiveMQBuffer buffer)
void	FederationDownstreamConfiguration.encode(ActiveMQBuffer buffer)
void	FederationPolicy.encode(ActiveMQBuffer buffer)
void	FederationPolicySet.encode(ActiveMQBuffer buffer)
void	FederationQueuePolicyConfiguration.encode(ActiveMQBuffer buffer)
void	FederationQueuePolicyConfiguration.Matcher.encode(ActiveMQBuffer buffer)
void	FederationStreamConfiguration.encode(ActiveMQBuffer buffer)
void	FederationTransformerConfiguration.encode(ActiveMQBuffer buffer)

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	Description
void	AbstractSequentialFile.write(ActiveMQBuffer bytes, boolean sync)
void	AbstractSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	SequentialFile.write(ActiveMQBuffer bytes, boolean sync)
void	SequentialFile.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	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 that return ActiveMQBuffer

Modifier and Type	Method	Description
ActiveMQBuffer	RecordInfo.wrapData()

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

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

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

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

Modifier and Type	Method	Description
final JournalHashMap.MapRecord<K,V>	AbstractHashMapPersister.decode(ActiveMQBuffer buffer, JournalHashMap.MapRecord<K,V> record, CoreMessageObjectPools pool)
protected abstract K	AbstractHashMapPersister.decodeKey(ActiveMQBuffer buffer)
protected abstract V	AbstractHashMapPersister.decodeValue(ActiveMQBuffer buffer, K key)
final void	AbstractHashMapPersister.encode(ActiveMQBuffer buffer, JournalHashMap.MapRecord<K,V> record)
protected abstract void	AbstractHashMapPersister.encodeKey(ActiveMQBuffer buffer, K key)
protected abstract void	AbstractHashMapPersister.encodeValue(ActiveMQBuffer buffer, V value)

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	Description
protected ActiveMQBuffer	AbstractJournalUpdateTask.getWritingChannel()

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

Modifier and Type	Method	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	Description
void	ByteArrayEncoding.decode(ActiveMQBuffer buffer)
void	JournalInternalRecord.decode(ActiveMQBuffer buffer)
void	ByteArrayEncoding.encode(ActiveMQBuffer buffer)
void	JournalAddRecord.encode(ActiveMQBuffer buffer)
void	JournalAddRecordTX.encode(ActiveMQBuffer buffer)
void	JournalCompleteRecordTX.encode(ActiveMQBuffer buffer)
void	JournalDeleteRecord.encode(ActiveMQBuffer buffer)
void	JournalDeleteRecordTX.encode(ActiveMQBuffer buffer)
void	JournalRollbackRecordTX.encode(ActiveMQBuffer buffer)

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

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

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

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

Modifier and Type	Method	Description
void	ManagementRemotingConnection.bufferReceived(Object connectionID, 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	Description
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	Description
ActiveMQBuffer	CoreMessage.getBodyBuffer()	The buffer to write the body.
ActiveMQBuffer	CoreMessage.getDataBuffer()	This will return the proper buffer to represent the data of the Message.
ActiveMQBuffer	MessageInternal.getEncodedBuffer()	Deprecated.
ActiveMQBuffer	MessageInternalImpl.getEncodedBuffer()	Deprecated.
ActiveMQBuffer	CoreMessage.getReadOnlyBodyBuffer()
ActiveMQBuffer	MessageInternal.getWholeBuffer()	Deprecated.
ActiveMQBuffer	MessageInternalImpl.getWholeBuffer()	Deprecated.

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

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

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	Description
void	PagedMessageImpl.decode(ActiveMQBuffer buffer)
void	PageTransactionInfoImpl.decode(ActiveMQBuffer buffer)
void	PagedMessageImpl.encode(ActiveMQBuffer buffer)
void	PageTransactionInfoImpl.encode(ActiveMQBuffer buffer)
static boolean	PagedMessageImpl.isLargeMessage(ActiveMQBuffer buffer)	This method won't move the readerIndex() of buffer.
boolean	PageReadWriter.PageRecordFilter.skip(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	Description
void	StorageManager.addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes)
T	Persister.decode(ActiveMQBuffer buffer, T record, CoreMessageObjectPools pool)
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	Description
void	PersistedAddressSetting.decode(ActiveMQBuffer buffer)	Deprecated.
void	PersistedAddressSettingJSON.decode(ActiveMQBuffer buffer)
void	PersistedBridgeConfiguration.decode(ActiveMQBuffer buffer)
void	PersistedConnector.decode(ActiveMQBuffer buffer)
void	PersistedDivertConfiguration.decode(ActiveMQBuffer buffer)
void	PersistedKeyValuePair.decode(ActiveMQBuffer buffer)
void	PersistedRole.decode(ActiveMQBuffer buffer)
void	PersistedSecuritySetting.decode(ActiveMQBuffer buffer)
void	PersistedUser.decode(ActiveMQBuffer buffer)
void	PersistedAddressSetting.encode(ActiveMQBuffer buffer)	Deprecated.
void	PersistedAddressSettingJSON.encode(ActiveMQBuffer buffer)
void	PersistedBridgeConfiguration.encode(ActiveMQBuffer buffer)
void	PersistedConnector.encode(ActiveMQBuffer buffer)
void	PersistedDivertConfiguration.encode(ActiveMQBuffer buffer)
void	PersistedKeyValuePair.encode(ActiveMQBuffer buffer)
void	PersistedRole.encode(ActiveMQBuffer buffer)
void	PersistedSecuritySetting.encode(ActiveMQBuffer buffer)
void	PersistedUser.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	Description
ActiveMQBuffer	LargeBody.getReadOnlyBodyBuffer()
ActiveMQBuffer	LargeServerMessageImpl.getReadOnlyBodyBuffer()

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

Modifier and Type	Method	Description
void	LargeBody.addBytes(ActiveMQBuffer bytes)
void	LargeServerMessageImpl.addBytes(ActiveMQBuffer bytes, boolean initialHeader)
final void	JDBCJournalStorageManager.addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes)
void	JournalStorageManager.addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes)
void	BatchingIDGenerator.IDCounterEncoding.decode(ActiveMQBuffer buffer)
void	BufferSplitter.PartialEncoding.decode(ActiveMQBuffer buffer)
void	LargeServerMessageImpl.decode(ActiveMQBuffer buffer1)
void	BatchingIDGenerator.IDCounterEncoding.encode(ActiveMQBuffer buffer)
void	BufferSplitter.PartialEncoding.encode(ActiveMQBuffer buffer)
void	LargeServerMessageImpl.encode(ActiveMQBuffer buffer1)
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 PersistedSecuritySetting	AbstractJournalStorageManager.newSecurityRecord(long id, ActiveMQBuffer buffer)
protected abstract LargeServerMessage	AbstractJournalStorageManager.parseLargeMessage(ActiveMQBuffer buff)
protected LargeServerMessage	JournalStorageManager.parseLargeMessage(ActiveMQBuffer buff)
static void	BufferSplitter.split(ActiveMQBuffer buffer, int splitSize, Consumer<EncodingSupport> target)

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	Description
void	AddressStatusEncoding.decode(ActiveMQBuffer buffer)
void	CursorAckRecordEncoding.decode(ActiveMQBuffer buffer)
void	DeleteEncoding.decode(ActiveMQBuffer buffer)
void	DeliveryCountUpdateEncoding.decode(ActiveMQBuffer buffer)
void	DuplicateIDEncoding.decode(ActiveMQBuffer buffer)
void	GroupingEncoding.decode(ActiveMQBuffer buffer)
void	HeuristicCompletionEncoding.decode(ActiveMQBuffer buffer)
LargeServerMessage	LargeMessagePersister.decode(ActiveMQBuffer buffer, LargeServerMessage message, CoreMessageObjectPools objectPools)
void	PageCountPendingImpl.decode(ActiveMQBuffer buffer)
void	PageCountRecord.decode(ActiveMQBuffer buffer)
void	PageCountRecordInc.decode(ActiveMQBuffer buffer)
void	PageUpdateTXEncoding.decode(ActiveMQBuffer buffer)
void	PendingLargeMessageEncoding.decode(ActiveMQBuffer buffer)
void	PersistentAddressBindingEncoding.decode(ActiveMQBuffer buffer)
void	PersistentQueueBindingEncoding.decode(ActiveMQBuffer buffer)
void	QueueEncoding.decode(ActiveMQBuffer buffer)
void	QueueStatusEncoding.decode(ActiveMQBuffer buffer)
void	ScheduledDeliveryEncoding.decode(ActiveMQBuffer buffer)
void	XidEncoding.decode(ActiveMQBuffer buffer)
protected AckRetry	AckRetry.Persister.decodeKey(ActiveMQBuffer buffer)
protected AckRetry	AckRetry.Persister.decodeValue(ActiveMQBuffer buffer, AckRetry key)
void	AddressStatusEncoding.encode(ActiveMQBuffer buffer)
void	CursorAckRecordEncoding.encode(ActiveMQBuffer buffer)
void	DeleteEncoding.encode(ActiveMQBuffer buffer)
void	DeliveryCountUpdateEncoding.encode(ActiveMQBuffer buffer)
void	DuplicateIDEncoding.encode(ActiveMQBuffer buffer)
void	GroupingEncoding.encode(ActiveMQBuffer buffer)
void	HeuristicCompletionEncoding.encode(ActiveMQBuffer buffer)
void	LargeMessagePersister.encode(ActiveMQBuffer buffer, LargeServerMessage message)
void	PageCountPendingImpl.encode(ActiveMQBuffer buffer)
void	PageCountRecord.encode(ActiveMQBuffer buffer)
void	PageCountRecordInc.encode(ActiveMQBuffer buffer)
void	PageUpdateTXEncoding.encode(ActiveMQBuffer buffer)
void	PendingLargeMessageEncoding.encode(ActiveMQBuffer buffer)
void	PersistentAddressBindingEncoding.encode(ActiveMQBuffer buffer)
void	PersistentQueueBindingEncoding.encode(ActiveMQBuffer buffer)
void	QueueEncoding.encode(ActiveMQBuffer buffer)
void	QueueStatusEncoding.encode(ActiveMQBuffer buffer)
void	ScheduledDeliveryEncoding.encode(ActiveMQBuffer buffer)
void	XidEncoding.encode(ActiveMQBuffer buffer)
protected void	AckRetry.Persister.encodeKey(ActiveMQBuffer buffer, AckRetry key)
protected void	AckRetry.Persister.encodeValue(ActiveMQBuffer buffer, AckRetry value)

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

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

Modifier and Type	Method	Description
void	NullStorageManager.addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes)

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	Description
Packet	ClientPacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)
Packet	ServerPacketDecoder.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	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	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	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	Description
void	RemotingConnectionImpl.bufferReceived(Object connectionID, ActiveMQBuffer buffer)
abstract Packet	PacketDecoder.decode(ActiveMQBuffer in, CoreRemotingConnection connection)
void	PacketImpl.decode(ActiveMQBuffer buffer)
void	PacketImpl.decodeRest(ActiveMQBuffer buffer)
protected void	PacketImpl.encodeHeader(ActiveMQBuffer buffer)
void	PacketImpl.encodeRest(ActiveMQBuffer buffer)
void	PacketImpl.encodeRest(ActiveMQBuffer buffer, CoreRemotingConnection coreRemotingConnection)
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 that return ActiveMQBuffer

Modifier and Type	Method	Description
ActiveMQBuffer	SessionReceiveMessage_1X.encode(CoreRemotingConnection connection)

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

Modifier and Type	Method	Description
void	ActiveMQExceptionMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	ActiveMQExceptionMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupRegistrationMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupReplicationStartFailedMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupRequestMessage.decodeRest(ActiveMQBuffer buffer)
void	BackupResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	CheckFailoverMessage.decodeRest(ActiveMQBuffer buffer)
void	CheckFailoverReplyMessage.decodeRest(ActiveMQBuffer buffer)
void	ClusterConnectMessage.decodeRest(ActiveMQBuffer buffer)
void	ClusterConnectReplyMessage.decodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V4.decodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateAddressMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateProducerMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateSessionMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	CreateSessionMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateSessionResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage.decodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerMessage.decodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerWithKillMessage.decodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage.decodeRest(ActiveMQBuffer buffer)
void	FederationStreamConnectMessage.decodeRest(ActiveMQBuffer buffer)
void	NodeAnnounceMessage.decodeRest(ActiveMQBuffer buffer)
void	NullResponseMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	PacketsConfirmedMessage.decodeRest(ActiveMQBuffer buffer)
void	Ping.decodeRest(ActiveMQBuffer buffer)
void	QuorumVoteMessage.decodeRest(ActiveMQBuffer buffer)
void	QuorumVoteReplyMessage.decodeRest(ActiveMQBuffer buffer)
void	ReattachSessionMessage.decodeRest(ActiveMQBuffer buffer)
void	ReattachSessionResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	RemoveProducerMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationAddMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationAddTXMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationCommitMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteTXMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageBeginMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageEndMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageWriteMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationPageEventMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationPageWriteMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationPrepareMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationPrimaryIsStoppingMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationResponseMessageV2.decodeRest(ActiveMQBuffer buffer)
void	ReplicationStartSyncMessage.decodeRest(ActiveMQBuffer buffer)
void	ReplicationSyncFileMessage.decodeRest(ActiveMQBuffer buffer)
void	RollbackMessage.decodeRest(ActiveMQBuffer buffer)
void	ScaleDownAnnounceMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionAcknowledgeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessageV2.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V4.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V5.decodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionCommitMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionConsumerCloseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionConsumerFlowCreditMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionContinuationMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionCreateConsumerMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionDeleteQueueMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionExpireMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionForceConsumerDelivery.decodeRest(ActiveMQBuffer buffer)
void	SessionIndividualAcknowledgeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsFailMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveClientLargeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveContinuationMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveLargeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionReceiveMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionRequestProducerCreditsMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionSendLargeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage_V3.decodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAAfterFailedMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXACommitMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAEndMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAForgetMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAGetInDoubtXidsResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAGetTimeoutResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAJoinMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAPrepareMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAResponseMessage_V2.decodeRest(ActiveMQBuffer buffer)
void	SessionXAResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAResumeMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXARollbackMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutResponseMessage.decodeRest(ActiveMQBuffer buffer)
void	SessionXAStartMessage.decodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessage.decodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessageV2.decodeRest(ActiveMQBuffer buffer)
protected FederationDownstreamConfiguration	FederationDownstreamConnectMessage.decodeStreamConfiguration(ActiveMQBuffer buffer)
protected abstract T	FederationStreamConnectMessage.decodeStreamConfiguration(ActiveMQBuffer buffer)
void	ActiveMQExceptionMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	ActiveMQExceptionMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupRegistrationMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupReplicationStartFailedMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupRequestMessage.encodeRest(ActiveMQBuffer buffer)
void	BackupResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	CheckFailoverMessage.encodeRest(ActiveMQBuffer buffer)
void	CheckFailoverReplyMessage.encodeRest(ActiveMQBuffer buffer)
void	ClusterConnectMessage.encodeRest(ActiveMQBuffer buffer)
void	ClusterConnectReplyMessage.encodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage_V4.encodeRest(ActiveMQBuffer buffer)
void	ClusterTopologyChangeMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateAddressMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateProducerMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	CreateQueueMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateSessionMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	CreateSessionMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateSessionResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	CreateSharedQueueMessage.encodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerMessage.encodeRest(ActiveMQBuffer buffer)
void	DisconnectConsumerWithKillMessage.encodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	DisconnectMessage.encodeRest(ActiveMQBuffer buffer)
void	FederationStreamConnectMessage.encodeRest(ActiveMQBuffer buffer)
void	NodeAnnounceMessage.encodeRest(ActiveMQBuffer buffer)
void	NullResponseMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	PacketsConfirmedMessage.encodeRest(ActiveMQBuffer buffer)
void	Ping.encodeRest(ActiveMQBuffer buffer)
void	QuorumVoteMessage.encodeRest(ActiveMQBuffer buffer)
void	QuorumVoteReplyMessage.encodeRest(ActiveMQBuffer buffer)
void	ReattachSessionMessage.encodeRest(ActiveMQBuffer buffer)
void	ReattachSessionResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	RemoveProducerMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationAddMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationAddTXMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationCommitMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationDeleteTXMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageBeginMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageEndMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationLargeMessageWriteMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationPageEventMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationPageWriteMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationPrepareMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationPrimaryIsStoppingMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationResponseMessageV2.encodeRest(ActiveMQBuffer buffer)
void	ReplicationStartSyncMessage.encodeRest(ActiveMQBuffer buffer)
void	ReplicationSyncFileMessage.encodeRest(ActiveMQBuffer buffer)
void	RollbackMessage.encodeRest(ActiveMQBuffer buffer)
void	ScaleDownAnnounceMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionAcknowledgeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionAddMetaDataMessageV2.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V4.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage_V5.encodeRest(ActiveMQBuffer buffer)
void	SessionBindingQueryResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionCommitMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionConsumerCloseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionConsumerFlowCreditMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionContinuationMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionCreateConsumerMessage.encodeRest(ActiveMQBuffer buffer, CoreRemotingConnection coreRemotingConnection)
void	SessionDeleteQueueMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionExpireMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionForceConsumerDelivery.encodeRest(ActiveMQBuffer buffer)
void	SessionIndividualAcknowledgeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsFailMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionProducerCreditsMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	SessionQueueQueryResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveContinuationMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveLargeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveMessage_1X.encodeRest(ActiveMQBuffer buffer)
void	SessionReceiveMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionRequestProducerCreditsMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	SessionSendContinuationMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionSendLargeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage_1X.encodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage_V3.encodeRest(ActiveMQBuffer buffer)
void	SessionSendMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAAfterFailedMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXACommitMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAEndMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAForgetMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAGetInDoubtXidsResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAGetTimeoutResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAJoinMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAPrepareMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAResponseMessage_V2.encodeRest(ActiveMQBuffer buffer)
void	SessionXAResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAResumeMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXARollbackMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXASetTimeoutResponseMessage.encodeRest(ActiveMQBuffer buffer)
void	SessionXAStartMessage.encodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessage.encodeRest(ActiveMQBuffer buffer)
void	SubscribeClusterTopologyUpdatesMessageV2.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	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	Description
void	InVMConnection.write(ActiveMQBuffer buffer)
void	InVMConnection.write(ActiveMQBuffer buffer, boolean requestFlush)
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	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	Description
final void	NettyConnection.write(ActiveMQBuffer buffer)
void	NettyConnection.write(ActiveMQBuffer buffer, boolean requestFlush)
final void	NettyConnection.write(ActiveMQBuffer buffer, boolean flush, boolean batched)
final void	NettyConnection.write(ActiveMQBuffer buffer, boolean flush, boolean batched, io.netty.channel.ChannelFutureListener futureListener)

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

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

Modifier and Type	Method	Description
default void	LargeServerMessage.addBytes(ActiveMQBuffer bytes)
void	LargeServerMessage.addBytes(ActiveMQBuffer bytes, boolean initialHeader)

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

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

Modifier and Type	Method	Description
void	BooleanVote.decode(ActiveMQBuffer buff)
Vote	QuorumVoteHandler.decode(ActiveMQBuffer voteBuffer)
void	ServerConnectVote.decode(ActiveMQBuffer buff)
abstract void	Vote.decode(ActiveMQBuffer buff)
void	BooleanVote.encode(ActiveMQBuffer buff)
void	ServerConnectVote.encode(ActiveMQBuffer buff)
abstract void	Vote.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	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	Description
void	AddressSettings.decode(ActiveMQBuffer buffer)
void	AddressSettings.decode(ActiveMQBuffer buffer, boolean tryCompatible)
void	ResourceLimitSettings.decode(ActiveMQBuffer buffer)
void	AddressSettings.encode(ActiveMQBuffer buffer)
void	ResourceLimitSettings.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	Description
int	JDBCSequentialFile.jdbcWrite(ActiveMQBuffer buffer, IOCallback callback)
int	JDBCSequentialFile.jdbcWrite(ActiveMQBuffer buffer, IOCallback callback, boolean append)
void	JDBCSequentialFile.sendToDB(ActiveMQBuffer bytes, IOCallback callback, boolean append)
void	JDBCSequentialFile.write(ActiveMQBuffer bytes, boolean sync)
void	JDBCSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)

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

Modifier	Constructor	Description
	ScheduledWrite(ActiveMQBuffer amqBuffer, IOCallback callback, boolean append)

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	Description
void	PersistedBindings.decode(ActiveMQBuffer buffer)
void	PersistedConnectionFactory.decode(ActiveMQBuffer buffer)
void	PersistedDestination.decode(ActiveMQBuffer buffer)
void	PersistedBindings.encode(ActiveMQBuffer buffer)
void	PersistedConnectionFactory.encode(ActiveMQBuffer buffer)
void	PersistedDestination.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	Description
void	ConnectionFactoryConfigurationImpl.decode(ActiveMQBuffer buffer)
static TransportConfiguration	TransportConfigurationEncodingSupport.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	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	Description
ActiveMQBuffer	AbstractRemotingConnection.createTransportBuffer(int size)
ActiveMQBuffer	RemotingConnection.createTransportBuffer(int size)	creates a new ActiveMQBuffer of the specified size.

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

Modifier and Type	Method	Description
void	AbstractRemotingConnection.bufferReceived(Object connectionID, ActiveMQBuffer buffer)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager)
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	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	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 requestFlush)	writes the buffer to the connection and if flush is true request to flush the buffer (and any previous un-flushed ones) into the wire.
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	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	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 byte[]	BufferHelper.safeReadBytes(ActiveMQBuffer in)
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

Modifier	Constructor	Description
	ActiveMQBufferInputStream(ActiveMQBuffer paramByteBuffer)