Uses of Interface
org.apache.activemq.artemis.api.core.ActiveMQBuffer
-
-
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 arraystatic ActiveMQBuffer
ActiveMQBuffers. dynamicBuffer(int size)
Creates a self-expanding ActiveMQBuffer with the given initial sizestatic ActiveMQBuffer
ActiveMQBuffers. fixedBuffer(int size)
Creates a fixed ActiveMQBuffer of the given sizeActiveMQBuffer
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.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 currentreaderIndex
and increases thereaderIndex
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 arraystatic 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 bufferstatic 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 bufferMethods 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 absoluteindex
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 absoluteindex
.void
ActiveMQBuffer. getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
.void
Message. persist(ActiveMQBuffer targetRecord)
void
ActiveMQBuffer. readBytes(ActiveMQBuffer dst)
Transfers this buffer's data to the specified destination starting at the currentreaderIndex
until the destination becomes non-writable, and increases thereaderIndex
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 currentreaderIndex
and increases thereaderIndex
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 currentreaderIndex
and increases thereaderIndex
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 absoluteindex
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 absoluteindex
.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 absoluteindex
.void
ActiveMQBuffer. writeBytes(ActiveMQBuffer src, int length)
Transfers the specified source buffer's data to this buffer starting at the currentwriterIndex
and increases thewriterIndex
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 currentwriterIndex
and increases thewriterIndex
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-idvoid
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 toBufferHandler.bufferReceived(Object, ActiveMQBuffer)
.void
Connection. write(ActiveMQBuffer buffer)
writes the buffer to the connection with no flushing or batchingvoid
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.
-