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 ActiveMQBufferActiveMQBuffer. copy()Returns a copy of this buffer's readable bytes.ActiveMQBufferActiveMQBuffer. copy(int index, int length)Returns a copy of this buffer's sub-region.ActiveMQBufferActiveMQBuffer. duplicate()Returns a buffer which shares the whole region of this buffer.static ActiveMQBufferActiveMQBuffers. dynamicBuffer(byte[] bytes)Creates a self-expanding ActiveMQBuffer filled with the given byte arraystatic ActiveMQBufferActiveMQBuffers. dynamicBuffer(int size)Creates a self-expanding ActiveMQBuffer with the given initial sizestatic ActiveMQBufferActiveMQBuffers. fixedBuffer(int size)Creates a fixed ActiveMQBuffer of the given sizeActiveMQBufferICoreMessage. getBodyBuffer()The buffer to write the body.default ActiveMQBufferMessage. getBodyBuffer()Deprecated.do not use this, use through ICoreMessage or ClientMessage Warning: if you need to read the content of a message use getDataBuffer().ActiveMQBufferICoreMessage. getDataBuffer()Returns a readOnlyBodyBuffer or a decompressed one if the message is compressed.ActiveMQBufferICoreMessage. getReadOnlyBodyBuffer()Returns a new Buffer slicing the current Body.static ActiveMQBufferActiveMQBuffers. pooledBuffer(int size)ActiveMQBufferActiveMQBuffer. readSlice(int length)Returns a new slice of this buffer's sub-region starting at the currentreaderIndexand increases thereaderIndexby the size of the new slice (=length).ActiveMQBufferActiveMQBuffer. slice()Returns a slice of this buffer's readable bytes.ActiveMQBufferActiveMQBuffer. slice(int index, int length)Returns a slice of this buffer's sub-region.static ActiveMQBufferActiveMQBuffers. wrappedBuffer(byte[] underlying)Creates an ActiveMQBuffer wrapping an underlying byte arraystatic ActiveMQBufferActiveMQBuffers. 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 ActiveMQBufferActiveMQBuffers. 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 voidTransportConfiguration. decode(ActiveMQBuffer buffer)Decodes this TransportConfiguration from a buffer.voidTransportConfiguration. encode(ActiveMQBuffer buffer)Encodes this TransportConfiguration into a buffer.voidActiveMQBuffer. getBytes(int index, ActiveMQBuffer dst)Transfers this buffer's data to the specified destination starting at the specified absoluteindexuntil the destination becomes non-writable.voidActiveMQBuffer. getBytes(int index, ActiveMQBuffer dst, int length)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.voidActiveMQBuffer. getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.voidMessage. persist(ActiveMQBuffer targetRecord)voidActiveMQBuffer. readBytes(ActiveMQBuffer dst)Transfers this buffer's data to the specified destination starting at the currentreaderIndexuntil the destination becomes non-writable, and increases thereaderIndexby the number of the transferred bytes.voidActiveMQBuffer. readBytes(ActiveMQBuffer dst, int length)Transfers this buffer's data to the specified destination starting at the currentreaderIndexand increases thereaderIndexby the number of the transferred bytes (=length).voidActiveMQBuffer. readBytes(ActiveMQBuffer dst, int dstIndex, int length)Transfers this buffer's data to the specified destination starting at the currentreaderIndexand increases thereaderIndexby the number of the transferred bytes (=length).voidMessage. reloadPersistence(ActiveMQBuffer record, CoreMessageObjectPools pools)voidActiveMQBuffer. setBytes(int index, ActiveMQBuffer src)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindexuntil the destination becomes unreadable.voidActiveMQBuffer. setBytes(int index, ActiveMQBuffer src, int length)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex.voidActiveMQBuffer. setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex.voidActiveMQBuffer. writeBytes(ActiveMQBuffer src, int length)Transfers the specified source buffer's data to this buffer starting at the currentwriterIndexand increases thewriterIndexby the number of the transferred bytes (=length).voidActiveMQBuffer. writeBytes(ActiveMQBuffer src, int srcIndex, int length)Transfers the specified source buffer's data to this buffer starting at the currentwriterIndexand increases thewriterIndexby 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 ActiveMQBufferClientMessage. 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 classChannelBufferWrapperclassResetLimitWrappedActiveMQBufferA ResetLimitWrappedActiveMQBufferMethods in org.apache.activemq.artemis.core.buffers.impl that return ActiveMQBuffer Modifier and Type Method Description ActiveMQBufferChannelBufferWrapper. copy()ActiveMQBufferChannelBufferWrapper. copy(int index, int length)ActiveMQBufferChannelBufferWrapper. duplicate()ActiveMQBufferChannelBufferWrapper. readSlice(int length)ActiveMQBufferChannelBufferWrapper. slice()ActiveMQBufferChannelBufferWrapper. slice(int index, int length)Methods in org.apache.activemq.artemis.core.buffers.impl with parameters of type ActiveMQBuffer Modifier and Type Method Description voidChannelBufferWrapper. getBytes(int index, ActiveMQBuffer dst)voidChannelBufferWrapper. getBytes(int index, ActiveMQBuffer dst, int length)voidChannelBufferWrapper. getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)voidChannelBufferWrapper. readBytes(ActiveMQBuffer dst)voidChannelBufferWrapper. readBytes(ActiveMQBuffer dst, int length)voidChannelBufferWrapper. readBytes(ActiveMQBuffer dst, int dstIndex, int length)voidChannelBufferWrapper. setBytes(int index, ActiveMQBuffer src)voidChannelBufferWrapper. setBytes(int index, ActiveMQBuffer src, int length)voidChannelBufferWrapper. setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)voidResetLimitWrappedActiveMQBuffer. setBytes(int index, ActiveMQBuffer src)voidResetLimitWrappedActiveMQBuffer. setBytes(int index, ActiveMQBuffer src, int length)voidResetLimitWrappedActiveMQBuffer. setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)voidChannelBufferWrapper. writeBytes(ActiveMQBuffer src, int length)voidChannelBufferWrapper. writeBytes(ActiveMQBuffer src, int srcIndex, int length)voidResetLimitWrappedActiveMQBuffer. writeBytes(ActiveMQBuffer src, int length)voidResetLimitWrappedActiveMQBuffer. writeBytes(ActiveMQBuffer src, int srcIndex, int length)Constructors in org.apache.activemq.artemis.core.buffers.impl with parameters of type ActiveMQBuffer 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 interfaceLargeMessageControllerClasses in org.apache.activemq.artemis.core.client.impl that implement ActiveMQBuffer Modifier and Type Class Description classLargeMessageControllerImplThis class aggregates severalSessionReceiveContinuationMessageas 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 ActiveMQBufferLargeMessageControllerImpl. copy()ActiveMQBufferLargeMessageControllerImpl. copy(int index, int length)ActiveMQBufferLargeMessageControllerImpl. duplicate()ActiveMQBufferClientLargeMessageImpl. getBodyBuffer()ActiveMQBufferLargeMessageControllerImpl. readSlice(int length)ActiveMQBufferLargeMessageControllerImpl. slice()ActiveMQBufferLargeMessageControllerImpl. slice(int index, int length)Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ActiveMQBuffer Modifier and Type Method Description voidLargeMessageControllerImpl. getBytes(int index, ActiveMQBuffer dst)voidLargeMessageControllerImpl. getBytes(int index, ActiveMQBuffer dst, int length)voidLargeMessageControllerImpl. getBytes(int index, ActiveMQBuffer dst, int dstIndex, int length)voidLargeMessageControllerImpl. readBytes(ActiveMQBuffer dst)voidLargeMessageControllerImpl. readBytes(ActiveMQBuffer dst, int length)voidLargeMessageControllerImpl. readBytes(ActiveMQBuffer dst, int dstIndex, int length)voidLargeMessageControllerImpl. setBytes(int index, ActiveMQBuffer src)voidLargeMessageControllerImpl. setBytes(int index, ActiveMQBuffer src, int length)voidLargeMessageControllerImpl. setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)voidLargeMessageControllerImpl. writeBytes(ActiveMQBuffer src)voidLargeMessageControllerImpl. writeBytes(ActiveMQBuffer src, int length)voidLargeMessageControllerImpl. 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 voidBridgeConfiguration. decode(ActiveMQBuffer buffer)voidDivertConfiguration. decode(ActiveMQBuffer buffer)voidFederationConfiguration.Credentials. decode(ActiveMQBuffer buffer)voidBridgeConfiguration. encode(ActiveMQBuffer buffer)voidDivertConfiguration. encode(ActiveMQBuffer buffer)voidFederationConfiguration.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 voidFederationAddressPolicyConfiguration. decode(ActiveMQBuffer buffer)voidFederationAddressPolicyConfiguration.Matcher. decode(ActiveMQBuffer buffer)voidFederationConnectionConfiguration. decode(ActiveMQBuffer buffer)voidFederationDownstreamConfiguration. decode(ActiveMQBuffer buffer)voidFederationPolicy. decode(ActiveMQBuffer buffer)voidFederationPolicySet. decode(ActiveMQBuffer buffer)voidFederationQueuePolicyConfiguration. decode(ActiveMQBuffer buffer)voidFederationQueuePolicyConfiguration.Matcher. decode(ActiveMQBuffer buffer)voidFederationStreamConfiguration. decode(ActiveMQBuffer buffer)voidFederationTransformerConfiguration. decode(ActiveMQBuffer buffer)voidFederationAddressPolicyConfiguration. encode(ActiveMQBuffer buffer)voidFederationAddressPolicyConfiguration.Matcher. encode(ActiveMQBuffer buffer)voidFederationConnectionConfiguration. encode(ActiveMQBuffer buffer)voidFederationDownstreamConfiguration. encode(ActiveMQBuffer buffer)voidFederationPolicy. encode(ActiveMQBuffer buffer)voidFederationPolicySet. encode(ActiveMQBuffer buffer)voidFederationQueuePolicyConfiguration. encode(ActiveMQBuffer buffer)voidFederationQueuePolicyConfiguration.Matcher. encode(ActiveMQBuffer buffer)voidFederationStreamConfiguration. encode(ActiveMQBuffer buffer)voidFederationTransformerConfiguration. 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 voidAbstractSequentialFile. write(ActiveMQBuffer bytes, boolean sync)voidAbstractSequentialFile. write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)voidSequentialFile. write(ActiveMQBuffer bytes, boolean sync)voidSequentialFile. 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 voidTimedBuffer. 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 Description EncodingSupportEncoderPersister. decode(ActiveMQBuffer buffer, EncodingSupport record, CoreMessageObjectPools pools)voidEncodingSupport. decode(ActiveMQBuffer buffer)voidEncoderPersister. encode(ActiveMQBuffer buffer, EncodingSupport record)voidEncodingSupport. encode(ActiveMQBuffer buffer) -
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 ActiveMQBufferAbstractJournalUpdateTask. getWritingChannel()Methods in org.apache.activemq.artemis.core.journal.impl with parameters of type ActiveMQBuffer Modifier and Type Method Description static voidJournalImpl. 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 voidByteArrayEncoding. decode(ActiveMQBuffer buffer)voidJournalInternalRecord. decode(ActiveMQBuffer buffer)voidByteArrayEncoding. encode(ActiveMQBuffer buffer)voidJournalAddRecord. encode(ActiveMQBuffer buffer)voidJournalAddRecordTX. encode(ActiveMQBuffer buffer)voidJournalCompleteRecordTX. encode(ActiveMQBuffer buffer)voidJournalDeleteRecord. encode(ActiveMQBuffer buffer)voidJournalDeleteRecordTX. encode(ActiveMQBuffer buffer)voidJournalRollbackRecordTX. 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 ActiveMQBufferManagementRemotingConnection. createTransportBuffer(int size)Methods in org.apache.activemq.artemis.core.management.impl with parameters of type ActiveMQBuffer Modifier and Type Method Description voidManagementRemotingConnection. 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 intBodyEncoder. 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 ActiveMQBufferCoreMessage. getBodyBuffer()The buffer to write the body.ActiveMQBufferCoreMessage. getDataBuffer()This will return the proper buffer to represent the data of the Message.ActiveMQBufferMessageInternal. getEncodedBuffer()Deprecated.ActiveMQBufferMessageInternalImpl. getEncodedBuffer()Deprecated.ActiveMQBufferCoreMessage. getReadOnlyBodyBuffer()ActiveMQBufferMessageInternal. getWholeBuffer()Deprecated.ActiveMQBufferMessageInternalImpl. getWholeBuffer()Deprecated.Methods in org.apache.activemq.artemis.core.message.impl with parameters of type ActiveMQBuffer Modifier and Type Method Description MessageCoreMessagePersister. decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pool)voidMessageInternal. decodeFromBuffer(ActiveMQBuffer buffer)Deprecated.voidMessageInternalImpl. decodeFromBuffer(ActiveMQBuffer buffer)Deprecated.voidMessageInternal. decodeHeadersAndProperties(ActiveMQBuffer buffer)Deprecated.voidMessageInternalImpl. decodeHeadersAndProperties(ActiveMQBuffer buffer)Deprecated.voidCoreMessagePersister. encode(ActiveMQBuffer buffer, Message record)Sub classes must add the first short as the protocol-idvoidMessageInternal. encodeHeadersAndProperties(ActiveMQBuffer buffer)Deprecated.voidMessageInternalImpl. encodeHeadersAndProperties(ActiveMQBuffer buffer)Deprecated.voidCoreMessage. persist(ActiveMQBuffer targetRecord)voidMessageInternalImpl. persist(ActiveMQBuffer targetRecord)Deprecated.voidCoreMessage. reloadPersistence(ActiveMQBuffer record, CoreMessageObjectPools pools)voidMessageInternalImpl. 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 voidPagedMessageImpl. decode(ActiveMQBuffer buffer)voidPageTransactionInfoImpl. decode(ActiveMQBuffer buffer)voidPagedMessageImpl. encode(ActiveMQBuffer buffer)voidPageTransactionInfoImpl. encode(ActiveMQBuffer buffer)static booleanPagedMessageImpl. isLargeMessage(ActiveMQBuffer buffer)This method won't move thereaderIndex()ofbuffer. -
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 voidStorageManager. addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes)TPersister. decode(ActiveMQBuffer buffer, T record, CoreMessageObjectPools pool)voidPersister. 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 voidPersistedAddressSetting. decode(ActiveMQBuffer buffer)voidPersistedBridgeConfiguration. decode(ActiveMQBuffer buffer)voidPersistedDivertConfiguration. decode(ActiveMQBuffer buffer)voidPersistedKeyValuePair. decode(ActiveMQBuffer buffer)voidPersistedRole. decode(ActiveMQBuffer buffer)voidPersistedSecuritySetting. decode(ActiveMQBuffer buffer)voidPersistedUser. decode(ActiveMQBuffer buffer)voidPersistedAddressSetting. encode(ActiveMQBuffer buffer)voidPersistedBridgeConfiguration. encode(ActiveMQBuffer buffer)voidPersistedDivertConfiguration. encode(ActiveMQBuffer buffer)voidPersistedKeyValuePair. encode(ActiveMQBuffer buffer)voidPersistedRole. encode(ActiveMQBuffer buffer)voidPersistedSecuritySetting. encode(ActiveMQBuffer buffer)voidPersistedUser. 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 ActiveMQBufferLargeBody. getReadOnlyBodyBuffer()ActiveMQBufferLargeServerMessageImpl. getReadOnlyBodyBuffer()Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type ActiveMQBuffer Modifier and Type Method Description voidLargeBody. addBytes(ActiveMQBuffer bytes)voidLargeServerMessageImpl. addBytes(ActiveMQBuffer bytes, boolean initialHeader)voidJournalStorageManager. addBytesToLargeMessage(SequentialFile file, long messageId, ActiveMQBuffer bytes)voidBatchingIDGenerator.IDCounterEncoding. decode(ActiveMQBuffer buffer)voidBufferSplitter.PartialEncoding. decode(ActiveMQBuffer buffer)voidLargeServerMessageImpl. decode(ActiveMQBuffer buffer1)voidBatchingIDGenerator.IDCounterEncoding. encode(ActiveMQBuffer buffer)voidBufferSplitter.PartialEncoding. encode(ActiveMQBuffer buffer)voidLargeServerMessageImpl. encode(ActiveMQBuffer buffer1)voidBatchingIDGenerator. loadState(long journalID, ActiveMQBuffer buffer)protected static PersistentAddressBindingEncodingAbstractJournalStorageManager. newAddressBindingEncoding(long id, ActiveMQBuffer buffer)protected static PersistentQueueBindingEncodingAbstractJournalStorageManager. newQueueBindingEncoding(long id, ActiveMQBuffer buffer)protected static QueueStatusEncodingAbstractJournalStorageManager. newQueueStatusEncoding(long id, ActiveMQBuffer buffer)protected static PersistedSecuritySettingAbstractJournalStorageManager. newSecurityRecord(long id, ActiveMQBuffer buffer)protected abstract LargeServerMessageAbstractJournalStorageManager. parseLargeMessage(ActiveMQBuffer buff)protected LargeServerMessageJournalStorageManager. parseLargeMessage(ActiveMQBuffer buff)static voidBufferSplitter. 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 voidAddressStatusEncoding. decode(ActiveMQBuffer buffer)voidCursorAckRecordEncoding. decode(ActiveMQBuffer buffer)voidDeleteEncoding. decode(ActiveMQBuffer buffer)voidDeliveryCountUpdateEncoding. decode(ActiveMQBuffer buffer)voidDuplicateIDEncoding. decode(ActiveMQBuffer buffer)voidGroupingEncoding. decode(ActiveMQBuffer buffer)voidHeuristicCompletionEncoding. decode(ActiveMQBuffer buffer)LargeServerMessageLargeMessagePersister. decode(ActiveMQBuffer buffer, LargeServerMessage message, CoreMessageObjectPools objectPools)voidPageCountPendingImpl. decode(ActiveMQBuffer buffer)voidPageCountRecord. decode(ActiveMQBuffer buffer)voidPageCountRecordInc. decode(ActiveMQBuffer buffer)voidPageUpdateTXEncoding. decode(ActiveMQBuffer buffer)voidPendingLargeMessageEncoding. decode(ActiveMQBuffer buffer)voidPersistentAddressBindingEncoding. decode(ActiveMQBuffer buffer)voidPersistentQueueBindingEncoding. decode(ActiveMQBuffer buffer)voidQueueEncoding. decode(ActiveMQBuffer buffer)voidQueueStatusEncoding. decode(ActiveMQBuffer buffer)voidScheduledDeliveryEncoding. decode(ActiveMQBuffer buffer)voidXidEncoding. decode(ActiveMQBuffer buffer)voidAddressStatusEncoding. encode(ActiveMQBuffer buffer)voidCursorAckRecordEncoding. encode(ActiveMQBuffer buffer)voidDeleteEncoding. encode(ActiveMQBuffer buffer)voidDeliveryCountUpdateEncoding. encode(ActiveMQBuffer buffer)voidDuplicateIDEncoding. encode(ActiveMQBuffer buffer)voidGroupingEncoding. encode(ActiveMQBuffer buffer)voidHeuristicCompletionEncoding. encode(ActiveMQBuffer buffer)voidLargeMessagePersister. encode(ActiveMQBuffer buffer, LargeServerMessage message)voidPageCountPendingImpl. encode(ActiveMQBuffer buffer)voidPageCountRecord. encode(ActiveMQBuffer buffer)voidPageCountRecordInc. encode(ActiveMQBuffer buffer)voidPageUpdateTXEncoding. encode(ActiveMQBuffer buffer)voidPendingLargeMessageEncoding. encode(ActiveMQBuffer buffer)voidPersistentAddressBindingEncoding. encode(ActiveMQBuffer buffer)voidPersistentQueueBindingEncoding. encode(ActiveMQBuffer buffer)voidQueueEncoding. encode(ActiveMQBuffer buffer)voidQueueStatusEncoding. encode(ActiveMQBuffer buffer)voidScheduledDeliveryEncoding. encode(ActiveMQBuffer buffer)voidXidEncoding. encode(ActiveMQBuffer buffer) -
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 voidNullStorageManager. 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 PacketClientPacketDecoder. decode(ActiveMQBuffer in, CoreRemotingConnection connection)PacketServerPacketDecoder. 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 ActiveMQBufferPacket. encode(CoreRemotingConnection connection)Encodes the packet and returns aActiveMQBuffercontaining the dataMethods in org.apache.activemq.artemis.core.protocol.core with parameters of type ActiveMQBuffer Modifier and Type Method Description voidPacket. 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 ActiveMQBufferPacketImpl. createPacket(CoreRemotingConnection connection)ActiveMQBufferPacketImpl. encode(CoreRemotingConnection connection)Methods in org.apache.activemq.artemis.core.protocol.core.impl with parameters of type ActiveMQBuffer Modifier and Type Method Description voidRemotingConnectionImpl. bufferReceived(Object connectionID, ActiveMQBuffer buffer)abstract PacketPacketDecoder. decode(ActiveMQBuffer in, CoreRemotingConnection connection)voidPacketImpl. decode(ActiveMQBuffer buffer)voidPacketImpl. decodeRest(ActiveMQBuffer buffer)protected voidPacketImpl. encodeHeader(ActiveMQBuffer buffer)voidPacketImpl. encodeRest(ActiveMQBuffer buffer)voidPacketImpl. encodeRest(ActiveMQBuffer buffer, CoreRemotingConnection coreRemotingConnection)protected voidPacketImpl. encodeSize(ActiveMQBuffer buffer)voidCoreProtocolManager. handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)voidCoreProtocolManager. 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 ActiveMQBufferSessionReceiveMessage_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 voidActiveMQExceptionMessage_V2. decodeRest(ActiveMQBuffer buffer)voidActiveMQExceptionMessage. decodeRest(ActiveMQBuffer buffer)voidBackupRegistrationMessage. decodeRest(ActiveMQBuffer buffer)voidBackupReplicationStartFailedMessage. decodeRest(ActiveMQBuffer buffer)voidBackupRequestMessage. decodeRest(ActiveMQBuffer buffer)voidBackupResponseMessage. decodeRest(ActiveMQBuffer buffer)voidCheckFailoverMessage. decodeRest(ActiveMQBuffer buffer)voidCheckFailoverReplyMessage. decodeRest(ActiveMQBuffer buffer)voidClusterConnectMessage. decodeRest(ActiveMQBuffer buffer)voidClusterConnectReplyMessage. decodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage_V2. decodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage_V3. decodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage_V4. decodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage. decodeRest(ActiveMQBuffer buffer)voidCreateAddressMessage. decodeRest(ActiveMQBuffer buffer)voidCreateQueueMessage_V2. decodeRest(ActiveMQBuffer buffer)voidCreateQueueMessage. decodeRest(ActiveMQBuffer buffer)voidCreateSessionMessage_V2. decodeRest(ActiveMQBuffer buffer)voidCreateSessionMessage. decodeRest(ActiveMQBuffer buffer)voidCreateSessionResponseMessage. decodeRest(ActiveMQBuffer buffer)voidCreateSharedQueueMessage_V2. decodeRest(ActiveMQBuffer buffer)voidCreateSharedQueueMessage. decodeRest(ActiveMQBuffer buffer)voidDisconnectConsumerMessage. decodeRest(ActiveMQBuffer buffer)voidDisconnectConsumerWithKillMessage. decodeRest(ActiveMQBuffer buffer)voidDisconnectMessage_V2. decodeRest(ActiveMQBuffer buffer)voidDisconnectMessage_V3. decodeRest(ActiveMQBuffer buffer)voidDisconnectMessage. decodeRest(ActiveMQBuffer buffer)voidFederationStreamConnectMessage. decodeRest(ActiveMQBuffer buffer)voidNodeAnnounceMessage. decodeRest(ActiveMQBuffer buffer)voidNullResponseMessage_V2. decodeRest(ActiveMQBuffer buffer)voidPacketsConfirmedMessage. decodeRest(ActiveMQBuffer buffer)voidPing. decodeRest(ActiveMQBuffer buffer)voidQuorumVoteMessage. decodeRest(ActiveMQBuffer buffer)voidQuorumVoteReplyMessage. decodeRest(ActiveMQBuffer buffer)voidReattachSessionMessage. decodeRest(ActiveMQBuffer buffer)voidReattachSessionResponseMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationAddMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationAddTXMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationCommitMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationDeleteMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationDeleteTXMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationLargeMessageBeginMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationLargeMessageEndMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationLargeMessageWriteMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationLiveIsStoppingMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationPageEventMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationPageWriteMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationPrepareMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationResponseMessageV2. decodeRest(ActiveMQBuffer buffer)voidReplicationStartSyncMessage. decodeRest(ActiveMQBuffer buffer)voidReplicationSyncFileMessage. decodeRest(ActiveMQBuffer buffer)voidRollbackMessage. decodeRest(ActiveMQBuffer buffer)voidScaleDownAnnounceMessage. decodeRest(ActiveMQBuffer buffer)voidSessionAcknowledgeMessage. decodeRest(ActiveMQBuffer buffer)voidSessionAddMetaDataMessage. decodeRest(ActiveMQBuffer buffer)voidSessionAddMetaDataMessageV2. decodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryMessage. decodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage_V2. decodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage_V3. decodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage_V4. decodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage. decodeRest(ActiveMQBuffer buffer)voidSessionCommitMessage_V2. decodeRest(ActiveMQBuffer buffer)voidSessionConsumerCloseMessage. decodeRest(ActiveMQBuffer buffer)voidSessionConsumerFlowCreditMessage. decodeRest(ActiveMQBuffer buffer)voidSessionContinuationMessage. decodeRest(ActiveMQBuffer buffer)voidSessionCreateConsumerMessage. decodeRest(ActiveMQBuffer buffer)voidSessionDeleteQueueMessage. decodeRest(ActiveMQBuffer buffer)voidSessionExpireMessage. decodeRest(ActiveMQBuffer buffer)voidSessionForceConsumerDelivery. decodeRest(ActiveMQBuffer buffer)voidSessionIndividualAcknowledgeMessage. decodeRest(ActiveMQBuffer buffer)voidSessionProducerCreditsFailMessage. decodeRest(ActiveMQBuffer buffer)voidSessionProducerCreditsMessage. decodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryMessage. decodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryResponseMessage_V2. decodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryResponseMessage_V3. decodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryResponseMessage. decodeRest(ActiveMQBuffer buffer)voidSessionReceiveClientLargeMessage. decodeRest(ActiveMQBuffer buffer)voidSessionReceiveContinuationMessage. decodeRest(ActiveMQBuffer buffer)voidSessionReceiveLargeMessage. decodeRest(ActiveMQBuffer buffer)voidSessionReceiveMessage. decodeRest(ActiveMQBuffer buffer)voidSessionRequestProducerCreditsMessage. decodeRest(ActiveMQBuffer buffer)voidSessionSendContinuationMessage_V2. decodeRest(ActiveMQBuffer buffer)voidSessionSendContinuationMessage. decodeRest(ActiveMQBuffer buffer)voidSessionSendLargeMessage. decodeRest(ActiveMQBuffer buffer)voidSessionSendMessage_V2. decodeRest(ActiveMQBuffer buffer)voidSessionSendMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAAfterFailedMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXACommitMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAEndMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAForgetMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAGetInDoubtXidsResponseMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAGetTimeoutResponseMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAJoinMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAPrepareMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAResponseMessage_V2. decodeRest(ActiveMQBuffer buffer)voidSessionXAResponseMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAResumeMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXARollbackMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXASetTimeoutMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXASetTimeoutResponseMessage. decodeRest(ActiveMQBuffer buffer)voidSessionXAStartMessage. decodeRest(ActiveMQBuffer buffer)voidSubscribeClusterTopologyUpdatesMessage. decodeRest(ActiveMQBuffer buffer)voidSubscribeClusterTopologyUpdatesMessageV2. decodeRest(ActiveMQBuffer buffer)protected FederationDownstreamConfigurationFederationDownstreamConnectMessage. decodeStreamConfiguration(ActiveMQBuffer buffer)protected abstract TFederationStreamConnectMessage. decodeStreamConfiguration(ActiveMQBuffer buffer)voidActiveMQExceptionMessage_V2. encodeRest(ActiveMQBuffer buffer)voidActiveMQExceptionMessage. encodeRest(ActiveMQBuffer buffer)voidBackupRegistrationMessage. encodeRest(ActiveMQBuffer buffer)voidBackupReplicationStartFailedMessage. encodeRest(ActiveMQBuffer buffer)voidBackupRequestMessage. encodeRest(ActiveMQBuffer buffer)voidBackupResponseMessage. encodeRest(ActiveMQBuffer buffer)voidCheckFailoverMessage. encodeRest(ActiveMQBuffer buffer)voidCheckFailoverReplyMessage. encodeRest(ActiveMQBuffer buffer)voidClusterConnectMessage. encodeRest(ActiveMQBuffer buffer)voidClusterConnectReplyMessage. encodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage_V2. encodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage_V3. encodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage_V4. encodeRest(ActiveMQBuffer buffer)voidClusterTopologyChangeMessage. encodeRest(ActiveMQBuffer buffer)voidCreateAddressMessage. encodeRest(ActiveMQBuffer buffer)voidCreateQueueMessage_V2. encodeRest(ActiveMQBuffer buffer)voidCreateQueueMessage. encodeRest(ActiveMQBuffer buffer)voidCreateSessionMessage_V2. encodeRest(ActiveMQBuffer buffer)voidCreateSessionMessage. encodeRest(ActiveMQBuffer buffer)voidCreateSessionResponseMessage. encodeRest(ActiveMQBuffer buffer)voidCreateSharedQueueMessage_V2. encodeRest(ActiveMQBuffer buffer)voidCreateSharedQueueMessage. encodeRest(ActiveMQBuffer buffer)voidDisconnectConsumerMessage. encodeRest(ActiveMQBuffer buffer)voidDisconnectConsumerWithKillMessage. encodeRest(ActiveMQBuffer buffer)voidDisconnectMessage_V2. encodeRest(ActiveMQBuffer buffer)voidDisconnectMessage_V3. encodeRest(ActiveMQBuffer buffer)voidDisconnectMessage. encodeRest(ActiveMQBuffer buffer)voidFederationStreamConnectMessage. encodeRest(ActiveMQBuffer buffer)voidNodeAnnounceMessage. encodeRest(ActiveMQBuffer buffer)voidNullResponseMessage_V2. encodeRest(ActiveMQBuffer buffer)voidPacketsConfirmedMessage. encodeRest(ActiveMQBuffer buffer)voidPing. encodeRest(ActiveMQBuffer buffer)voidQuorumVoteMessage. encodeRest(ActiveMQBuffer buffer)voidQuorumVoteReplyMessage. encodeRest(ActiveMQBuffer buffer)voidReattachSessionMessage. encodeRest(ActiveMQBuffer buffer)voidReattachSessionResponseMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationAddMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationAddTXMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationCommitMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationDeleteMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationDeleteTXMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationLargeMessageBeginMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationLargeMessageEndMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationLargeMessageWriteMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationLiveIsStoppingMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationPageEventMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationPageWriteMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationPrepareMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationResponseMessageV2. encodeRest(ActiveMQBuffer buffer)voidReplicationStartSyncMessage. encodeRest(ActiveMQBuffer buffer)voidReplicationSyncFileMessage. encodeRest(ActiveMQBuffer buffer)voidRollbackMessage. encodeRest(ActiveMQBuffer buffer)voidScaleDownAnnounceMessage. encodeRest(ActiveMQBuffer buffer)voidSessionAcknowledgeMessage. encodeRest(ActiveMQBuffer buffer)voidSessionAddMetaDataMessage. encodeRest(ActiveMQBuffer buffer)voidSessionAddMetaDataMessageV2. encodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryMessage. encodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage_V2. encodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage_V3. encodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage_V4. encodeRest(ActiveMQBuffer buffer)voidSessionBindingQueryResponseMessage. encodeRest(ActiveMQBuffer buffer)voidSessionCommitMessage_V2. encodeRest(ActiveMQBuffer buffer)voidSessionConsumerCloseMessage. encodeRest(ActiveMQBuffer buffer)voidSessionConsumerFlowCreditMessage. encodeRest(ActiveMQBuffer buffer)voidSessionContinuationMessage. encodeRest(ActiveMQBuffer buffer)voidSessionCreateConsumerMessage. encodeRest(ActiveMQBuffer buffer, CoreRemotingConnection coreRemotingConnection)voidSessionDeleteQueueMessage. encodeRest(ActiveMQBuffer buffer)voidSessionExpireMessage. encodeRest(ActiveMQBuffer buffer)voidSessionForceConsumerDelivery. encodeRest(ActiveMQBuffer buffer)voidSessionIndividualAcknowledgeMessage. encodeRest(ActiveMQBuffer buffer)voidSessionProducerCreditsFailMessage. encodeRest(ActiveMQBuffer buffer)voidSessionProducerCreditsMessage. encodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryMessage. encodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryResponseMessage_V2. encodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryResponseMessage_V3. encodeRest(ActiveMQBuffer buffer)voidSessionQueueQueryResponseMessage. encodeRest(ActiveMQBuffer buffer)voidSessionReceiveContinuationMessage. encodeRest(ActiveMQBuffer buffer)voidSessionReceiveLargeMessage. encodeRest(ActiveMQBuffer buffer)voidSessionReceiveMessage_1X. encodeRest(ActiveMQBuffer buffer)voidSessionReceiveMessage. encodeRest(ActiveMQBuffer buffer)voidSessionRequestProducerCreditsMessage. encodeRest(ActiveMQBuffer buffer)voidSessionSendContinuationMessage_V2. encodeRest(ActiveMQBuffer buffer)voidSessionSendContinuationMessage. encodeRest(ActiveMQBuffer buffer)voidSessionSendLargeMessage. encodeRest(ActiveMQBuffer buffer)voidSessionSendMessage_1X. encodeRest(ActiveMQBuffer buffer)voidSessionSendMessage_V2. encodeRest(ActiveMQBuffer buffer)voidSessionSendMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAAfterFailedMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXACommitMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAEndMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAForgetMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAGetInDoubtXidsResponseMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAGetTimeoutResponseMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAJoinMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAPrepareMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAResponseMessage_V2. encodeRest(ActiveMQBuffer buffer)voidSessionXAResponseMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAResumeMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXARollbackMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXASetTimeoutMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXASetTimeoutResponseMessage. encodeRest(ActiveMQBuffer buffer)voidSessionXAStartMessage. encodeRest(ActiveMQBuffer buffer)voidSubscribeClusterTopologyUpdatesMessage. encodeRest(ActiveMQBuffer buffer)voidSubscribeClusterTopologyUpdatesMessageV2. 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 ActiveMQBufferInVMConnection. createTransportBuffer(int size)Methods in org.apache.activemq.artemis.core.remoting.impl.invm with parameters of type ActiveMQBuffer Modifier and Type Method Description voidInVMConnection. write(ActiveMQBuffer buffer)voidInVMConnection. write(ActiveMQBuffer buffer, boolean requestFlush)voidInVMConnection. write(ActiveMQBuffer buffer, boolean flush, boolean batch)voidInVMConnection. 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 ActiveMQBufferNettyConnection. createTransportBuffer(int size)Methods in org.apache.activemq.artemis.core.remoting.impl.netty with parameters of type ActiveMQBuffer Modifier and Type Method Description voidNettyConnection. write(ActiveMQBuffer buffer)voidNettyConnection. write(ActiveMQBuffer buffer, boolean requestFlush)voidNettyConnection. write(ActiveMQBuffer buffer, boolean flush, boolean batched)voidNettyConnection. 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 voidLargeServerMessage. addBytes(ActiveMQBuffer bytes)voidLargeServerMessage. addBytes(ActiveMQBuffer bytes, boolean initialHeader) -
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 Description voidBooleanVote. decode(ActiveMQBuffer buff)VoteQuorumVoteHandler. decode(ActiveMQBuffer voteBuffer)voidServerConnectVote. decode(ActiveMQBuffer buff)abstract voidVote. decode(ActiveMQBuffer buff)voidBooleanVote. encode(ActiveMQBuffer buff)voidServerConnectVote. encode(ActiveMQBuffer buff)abstract voidVote. 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 VoteServerConnectVoteHandler. 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 voidAddressSettings. decode(ActiveMQBuffer buffer)voidAddressSettings. decode(ActiveMQBuffer buffer, boolean tryCompatible)voidResourceLimitSettings. decode(ActiveMQBuffer buffer)voidAddressSettings. encode(ActiveMQBuffer buffer)voidResourceLimitSettings. 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 intJDBCSequentialFile. internalWrite(ActiveMQBuffer buffer, IOCallback callback)intJDBCSequentialFile. internalWrite(ActiveMQBuffer buffer, IOCallback callback, boolean append)voidJDBCSequentialFile. write(ActiveMQBuffer bytes, boolean sync)voidJDBCSequentialFile. write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)voidJDBCSequentialFile. write(ActiveMQBuffer bytes, boolean sync, 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 voidPersistedBindings. decode(ActiveMQBuffer buffer)voidPersistedConnectionFactory. decode(ActiveMQBuffer buffer)voidPersistedDestination. decode(ActiveMQBuffer buffer)voidPersistedBindings. encode(ActiveMQBuffer buffer)voidPersistedConnectionFactory. encode(ActiveMQBuffer buffer)voidPersistedDestination. 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 voidConnectionFactoryConfigurationImpl. decode(ActiveMQBuffer buffer)static TransportConfigurationTransportConfigurationEncodingSupport. decode(ActiveMQBuffer buffer)static List<Pair<TransportConfiguration,TransportConfiguration>>TransportConfigurationEncodingSupport. decodeConfigs(ActiveMQBuffer buffer)voidConnectionFactoryConfigurationImpl. encode(ActiveMQBuffer buffer)static voidTransportConfigurationEncodingSupport. encode(ActiveMQBuffer buffer, TransportConfiguration config)static voidTransportConfigurationEncodingSupport. 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 voidBytesMessageUtil. bytesMessageReset(ActiveMQBuffer message)static booleanBytesMessageUtil. bytesReadBoolean(ActiveMQBuffer message)static byteBytesMessageUtil. bytesReadByte(ActiveMQBuffer message)static intBytesMessageUtil. bytesReadBytes(ActiveMQBuffer message, byte[] value)static intBytesMessageUtil. bytesReadBytes(ActiveMQBuffer message, byte[] value, int length)static charBytesMessageUtil. bytesReadChar(ActiveMQBuffer message)static doubleBytesMessageUtil. bytesReadDouble(ActiveMQBuffer message)static floatBytesMessageUtil. bytesReadFloat(ActiveMQBuffer message)static intBytesMessageUtil. bytesReadInt(ActiveMQBuffer message)static longBytesMessageUtil. bytesReadLong(ActiveMQBuffer message)static shortBytesMessageUtil. bytesReadShort(ActiveMQBuffer message)static intBytesMessageUtil. bytesReadUnsignedByte(ActiveMQBuffer message)static intBytesMessageUtil. bytesReadUnsignedShort(ActiveMQBuffer message)static StringBytesMessageUtil. bytesReadUTF(ActiveMQBuffer message)static voidBytesMessageUtil. bytesWriteBoolean(ActiveMQBuffer message, boolean value)static voidBytesMessageUtil. bytesWriteByte(ActiveMQBuffer message, byte value)static voidBytesMessageUtil. bytesWriteBytes(ActiveMQBuffer message, byte[] value)static voidBytesMessageUtil. bytesWriteBytes(ActiveMQBuffer message, byte[] value, int offset, int length)static voidBytesMessageUtil. bytesWriteChar(ActiveMQBuffer message, char value)static voidBytesMessageUtil. bytesWriteDouble(ActiveMQBuffer message, double value)static voidBytesMessageUtil. bytesWriteFloat(ActiveMQBuffer message, float value)static voidBytesMessageUtil. bytesWriteInt(ActiveMQBuffer message, int value)static voidBytesMessageUtil. bytesWriteLong(ActiveMQBuffer message, long value)static booleanBytesMessageUtil. bytesWriteObject(ActiveMQBuffer message, Object value)Returns true if it could send the Object to any known formatstatic voidBytesMessageUtil. bytesWriteShort(ActiveMQBuffer message, short value)static voidBytesMessageUtil. bytesWriteUTF(ActiveMQBuffer message, String value)static TypedPropertiesMapMessageUtil. readBodyMap(ActiveMQBuffer message)Utility method to set the map on a message bodystatic voidMapMessageUtil. readBodyMap(ActiveMQBuffer message, TypedProperties map)Utility method to set the map on a message bodystatic SimpleStringTextMessageUtil. readBodyText(ActiveMQBuffer buff)Utility method to set the Text message on a message bodystatic booleanStreamMessageUtil. streamReadBoolean(ActiveMQBuffer buff)Method to read boolean values out of the Stream protocol existent on JMS Stream Messages Throws IllegalStateException if the type was invalidstatic byteStreamMessageUtil. streamReadByte(ActiveMQBuffer buff)static Pair<Integer,Integer>StreamMessageUtil. streamReadBytes(ActiveMQBuffer buff, int remainingBytes, byte[] value)Utility for reading bytes out of streaming.static charStreamMessageUtil. streamReadChar(ActiveMQBuffer buff)static doubleStreamMessageUtil. streamReadDouble(ActiveMQBuffer buff)static floatStreamMessageUtil. streamReadFloat(ActiveMQBuffer buff)static intStreamMessageUtil. streamReadInteger(ActiveMQBuffer buff)static longStreamMessageUtil. streamReadLong(ActiveMQBuffer buff)static ObjectStreamMessageUtil. streamReadObject(ActiveMQBuffer buff)static shortStreamMessageUtil. streamReadShort(ActiveMQBuffer buff)static StringStreamMessageUtil. streamReadString(ActiveMQBuffer buff)static voidMapMessageUtil. writeBodyMap(ActiveMQBuffer message, TypedProperties properties)Utility method to set the map on a message bodystatic voidTextMessageUtil. 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 ActiveMQBufferAbstractRemotingConnection. createTransportBuffer(int size)ActiveMQBufferRemotingConnection. 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 voidAbstractRemotingConnection. bufferReceived(Object connectionID, ActiveMQBuffer buffer)MessageMessagePersister. decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools)MessageMessagePersister. decode(ActiveMQBuffer buffer, Message record, CoreMessageObjectPools pools, StorageManager storageManager)voidMessagePersister. encode(ActiveMQBuffer buffer, Message record)Sub classes must add the first short as the protocol-idvoidProtocolManager. handleBuffer(RemotingConnection connection, ActiveMQBuffer buffer)voidProtocolManager. 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 ActiveMQBufferConnection. 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 voidBufferHandler. bufferReceived(Object connectionID, ActiveMQBuffer buffer)called by the remoting connection when a buffer is received.intBufferDecoder. isReadyToHandle(ActiveMQBuffer buffer)called by the remoting system prior toBufferHandler.bufferReceived(Object, ActiveMQBuffer).voidConnection. write(ActiveMQBuffer buffer)writes the buffer to the connection with no flushing or batchingvoidConnection. 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.voidConnection. 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.voidConnection. 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 ActiveMQBufferRandomUtil. randomBuffer(int size, long... data)Methods in org.apache.activemq.artemis.utils with parameters of type ActiveMQBuffer Modifier and Type Method Description static XidXidCodecSupport. decodeXid(ActiveMQBuffer in)static voidXidCodecSupport. encodeXid(Xid xid, ActiveMQBuffer out)static StringByteUtil. readLine(ActiveMQBuffer buffer)static BooleanBufferHelper. readNullableBoolean(ActiveMQBuffer buffer)static DoubleBufferHelper. readNullableDouble(ActiveMQBuffer buffer)static IntegerBufferHelper. readNullableInteger(ActiveMQBuffer buffer)static LongBufferHelper. readNullableLong(ActiveMQBuffer buffer)static StringBufferHelper. readNullableSimpleStringAsString(ActiveMQBuffer buffer)static StringUTF8Util. readUTF(ActiveMQBuffer input)static byte[]BufferHelper. safeReadBytes(ActiveMQBuffer in)static voidBufferHelper. writeAsNullableSimpleString(ActiveMQBuffer buffer, String str)static voidBufferHelper. writeAsSimpleString(ActiveMQBuffer buffer, String str)static voidBufferHelper. writeNullableBoolean(ActiveMQBuffer buffer, Boolean value)static voidBufferHelper. writeNullableDouble(ActiveMQBuffer buffer, Double value)static voidBufferHelper. writeNullableInteger(ActiveMQBuffer buffer, Integer value)static voidBufferHelper. writeNullableLong(ActiveMQBuffer buffer, Long value)Constructors in org.apache.activemq.artemis.utils with parameters of type ActiveMQBuffer Constructor Description ActiveMQBufferInputStream(ActiveMQBuffer paramByteBuffer)
-