Package org.apache.activemq.artemis.protocol.amqp.proton
package org.apache.activemq.artemis.protocol.amqp.proton
This package includes classes used on the interaction with Proton, including Context classes that will be translated
through the model event.
-
ClassDescriptionConstants derived from the AMQP specA Described Type wrapper for JMS selector values.Reader of
AMQPLargeMessagecontent which reads all bytes and completes once a non-partial delivery is read.A writer ofAMQPLargeMessagecontent that handles the read from large message file and write into the AMQP sender with some respect for the AMQP frame size in use by this connection.Reader of AMQP (non-large) messages which reads all bytes and decodes once a non-partial delivery is read.An writer of AMQP (non-large) messages or messages which will convert any non-AMQP message to AMQP before writing the encoded bytes into the AMQP sender.A Described Type wrapper for JMS no local option for MessageConsumer.Set of useful methods and definitions used in the AMQP protocol handlingUtility class that can generate and if enabled pool the binary tag values used to identify transfers over an AMQP link.Reader of tunneled large Core message that have been written as the body of an AMQP delivery with a custom message format that indicates this payload.Writer of tunneled large Core messages that will be written as the body of an AMQP delivery with a custom message format that indicates this payload.Reader of tunneled Core message that have been written as the body of an AMQP delivery with a custom message format that indicates this payload.Writer of tunneled Core messages that will be written as the body of an AMQP delivery with a custom message format that indicates this payload.Message constants used for handling the "tunneling" of other protocol messages in an AMQP delivery sent from one broker to another without conversion.The defaultSenderControllerinstance used by and sender context that is not assigned a custom controller.Message reader for incoming messages from and AMQP receiver context which will handle the read and decode of message payload into am AMQP message.Message writer for outgoing message from and AMQP sender context which will handle the encode and write of message payload into am AMQP sender.This servers as the default credit runnable which grants credit in batches based on a low water mark and a configured credit size to top the credit up to once the low water mark has been reached.An interface to handle deliveries, either messages, acks or transaction callsThis is the equivalent for the ServerProducerThis is the Equivalent for the ServerConsumer