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.config
org.apache.activemq.artemis.core.config.federation
org.apache.activemq.artemis.spi.core.protocol
org.apache.activemq.artemis.spi.core.remoting

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, org.apache.activemq.artemis.core.persistence.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.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.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, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools)
Message	MessagePersister.decode(ActiveMQBuffer buffer, Message record, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools pools, org.apache.activemq.artemis.core.persistence.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(org.apache.activemq.artemis.core.remoting.impl.netty.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.