Uses of Class
org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage

Packages that use AMQPMessage

Package	Description
org.apache.activemq.artemis.protocol.amqp.broker	This package includes classes used to interact with the broker.
org.apache.activemq.artemis.protocol.amqp.connect.federation
org.apache.activemq.artemis.protocol.amqp.converter	This package will include classes used to make convertions between Artemis and AMQP.

Uses of AMQPMessage in org.apache.activemq.artemis.protocol.amqp.broker

Subclasses of AMQPMessage in org.apache.activemq.artemis.protocol.amqp.broker

Modifier and Type	Class	Description
class	AMQPLargeMessage
class	AMQPStandardMessage

Subclasses with type arguments of type AMQPMessage in org.apache.activemq.artemis.protocol.amqp.broker

Modifier and Type	Class	Description
class	ProtonProtocolManager	A proton protocol manager, basically reads the Proton Input and maps proton resources to ActiveMQ Artemis resources

Subinterfaces with type arguments of type AMQPMessage in org.apache.activemq.artemis.protocol.amqp.broker

Modifier and Type	Interface	Description
interface	AmqpInterceptor

Methods in org.apache.activemq.artemis.protocol.amqp.broker that return AMQPMessage

Modifier and Type	Method	Description
final AMQPMessage	AMQPMessage.setAddress(String address)
final AMQPMessage	AMQPMessage.setAddress(SimpleString address)
final AMQPMessage	AMQPMessage.setAnnotation(SimpleString key, Object value)
final AMQPMessage	AMQPMessage.setExpiration(long expiration)
final AMQPMessage	AMQPMessage.setExtraProperties(org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties)
final AMQPMessage	AMQPMessage.setReplyTo(SimpleString address)
final AMQPMessage	AMQPMessage.setScheduledDeliveryTime(Long time)

Methods in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type AMQPMessage

Modifier and Type	Method	Description
static org.apache.qpid.proton.amqp.messaging.Header	AMQPMessageBrokerAccessor.getCurrentHeader(AMQPMessage message)	Warning: this is a method specific to the broker.
static org.apache.qpid.proton.amqp.messaging.Properties	AMQPMessageBrokerAccessor.getCurrentProperties(AMQPMessage message)	Warning: this is a method specific to the broker.
static org.apache.qpid.proton.amqp.messaging.ApplicationProperties	AMQPMessageBrokerAccessor.getDecodedApplicationProperties(AMQPMessage message)	Warning: this is a method specific to the broker.
static org.apache.qpid.proton.amqp.messaging.MessageAnnotations	AMQPMessageBrokerAccessor.getDecodedMessageAnnotations(AMQPMessage message)
static Object	AMQPMessageBrokerAccessor.getDeliveryAnnotationProperty(AMQPMessage message, org.apache.qpid.proton.amqp.Symbol symbol)	Warning: this is a method specific to the broker.
static org.apache.activemq.artemis.core.server.impl.AckReason	AMQPMessageBrokerAccessor.getMessageAnnotationAckReason(AMQPMessage message)
static Object	AMQPMessageBrokerAccessor.getMessageAnnotationProperty(AMQPMessage message, org.apache.qpid.proton.amqp.Symbol symbol)	Warning: this is a method specific to the broker.
static int	AMQPMessageBrokerAccessor.getRemainingBodyPosition(AMQPMessage message)	Warning: this is a method specific to the broker.

Constructors in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type AMQPMessage

Modifier	Constructor	Description
protected	AMQPMessage(AMQPMessage copy)

Uses of AMQPMessage in org.apache.activemq.artemis.protocol.amqp.connect.federation

Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return AMQPMessage

Modifier and Type	Method	Description
static AMQPMessage	AMQPFederationEventSupport.encodeAddressAddedEvent(String address)	Encode an event that indicates that an Address that belongs to a federation request which was not present at the time of the request or was later removed is now present and the remote should check for demand and attempt to federate the resource once again.
static AMQPMessage	AMQPFederationPolicySupport.encodeAddressPolicyControlMessage(FederationReceiveFromAddressPolicy policy)	Create an AMQP Message used to instruct the remote peer that it should perform Federation operations on the given FederationReceiveFromAddressPolicy.
static AMQPMessage	AMQPFederationEventSupport.encodeQueueAddedEvent(String address, String queue)	Encode an event that indicates that a Queue that belongs to a federation request which was not present at the time of the request or was later removed is now present and the remote should check for demand and attempt to federate the resource once again.
static AMQPMessage	AMQPFederationPolicySupport.encodeQueuePolicyControlMessage(FederationReceiveFromQueuePolicy policy)	Create an AMQP Message used to instruct the remote peer that it should perform Federation operations on the given FederationReceiveFromQueuePolicy.

Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPMessage

Modifier and Type	Method	Description
static Map<String,Object>	AMQPFederationEventSupport.decodeAddressAddedEvent(AMQPMessage message)	Decode and return the Map containing the event data for an Address that was the target of a previous federation request which was not present on the remote server or was later removed has now been (re)added.
static Map<String,Object>	AMQPFederationEventSupport.decodeQueueAddedEvent(AMQPMessage message)	Decode and return the Map containing the event data for a Queue that was the target of a previous federation request which was not present on the remote server or was later removed has now been (re)added.
static FederationReceiveFromAddressPolicy	AMQPFederationPolicySupport.decodeReceiveFromAddressPolicy(AMQPMessage message, WildcardConfiguration wildcardConfig)	Given an AMQP Message decode an FederationReceiveFromAddressPolicy from it and return the decoded value.
static FederationReceiveFromQueuePolicy	AMQPFederationPolicySupport.decodeReceiveFromQueuePolicy(AMQPMessage message, WildcardConfiguration wildcardConfig)	Given an AMQP Message decode an FederationReceiveFromQueuePolicy from it and return the decoded value.
void	AMQPFederationCommandDispatcher.sendCommand(AMQPMessage command)	Raw send command that accepts and AMQPMessage instance and routes it using the server post office instance.
void	AMQPFederationEventDispatcher.sendEvent(AMQPMessage event)	Raw event send API that accepts an AMQPMessage instance and routes it using the server post office instance.

Uses of AMQPMessage in org.apache.activemq.artemis.protocol.amqp.converter

Classes in org.apache.activemq.artemis.protocol.amqp.converter that implement interfaces with type arguments of type AMQPMessage

Modifier and Type	Class	Description
class	AMQPConverter

Methods in org.apache.activemq.artemis.protocol.amqp.converter that return AMQPMessage

Modifier and Type	Method	Description
static AMQPMessage	CoreAmqpConverter.checkAMQP(Message message, org.apache.activemq.artemis.core.persistence.StorageManager storageManager)
AMQPMessage	AMQPConverter.fromCore(ICoreMessage coreMessage, org.apache.activemq.artemis.core.persistence.StorageManager storageManager)
static AMQPMessage	CoreAmqpConverter.fromCore(ICoreMessage coreMessage, org.apache.activemq.artemis.core.persistence.StorageManager storageManager)

Methods in org.apache.activemq.artemis.protocol.amqp.converter with parameters of type AMQPMessage

Modifier and Type	Method	Description
ICoreMessage	AMQPConverter.toCore(AMQPMessage messageSource, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools)
static ICoreMessage	AmqpCoreConverter.toCore(AMQPMessage message, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools)
static ICoreMessage	AmqpCoreConverter.toCore(AMQPMessage message, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools, org.apache.qpid.proton.amqp.messaging.Header header, org.apache.qpid.proton.amqp.messaging.MessageAnnotations annotations, org.apache.qpid.proton.amqp.messaging.Properties properties, org.apache.qpid.proton.amqp.messaging.ApplicationProperties applicationProperties, org.apache.qpid.proton.amqp.messaging.Section body, org.apache.qpid.proton.amqp.messaging.Footer footer)