Uses of Class
org.apache.activemq.artemis.protocol.amqp.broker.AMQPMessage
Packages that use AMQPMessage
Package
Description
This package includes classes used to interact with the broker.
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.brokerSubclasses with type arguments of type AMQPMessage in org.apache.activemq.artemis.protocol.amqp.brokerModifier and TypeClassDescriptionclassA proton protocol manager, basically reads the Proton Input and maps proton resources to ActiveMQ Artemis resourcesSubinterfaces with type arguments of type AMQPMessage in org.apache.activemq.artemis.protocol.amqp.brokerMethods in org.apache.activemq.artemis.protocol.amqp.broker that return AMQPMessageModifier and TypeMethodDescriptionfinal AMQPMessageAMQPMessage.setAddress(String address) final AMQPMessageAMQPMessage.setAddress(SimpleString address) final AMQPMessageAMQPMessage.setAnnotation(SimpleString key, Object value) final AMQPMessageAMQPMessage.setExpiration(long expiration) final AMQPMessageAMQPMessage.setExtraProperties(org.apache.activemq.artemis.utils.collections.TypedProperties extraProperties) final AMQPMessageAMQPMessage.setReplyTo(SimpleString address) final AMQPMessageAMQPMessage.setScheduledDeliveryTime(Long time) Methods in org.apache.activemq.artemis.protocol.amqp.broker with parameters of type AMQPMessageModifier and TypeMethodDescriptionstatic org.apache.qpid.proton.amqp.messaging.HeaderAMQPMessageBrokerAccessor.getCurrentHeader(AMQPMessage message) Warning: this is a method specific to the broker.static org.apache.qpid.proton.amqp.messaging.PropertiesAMQPMessageBrokerAccessor.getCurrentProperties(AMQPMessage message) Warning: this is a method specific to the broker.static org.apache.qpid.proton.amqp.messaging.ApplicationPropertiesAMQPMessageBrokerAccessor.getDecodedApplicationProperties(AMQPMessage message) Warning: this is a method specific to the broker.static org.apache.qpid.proton.amqp.messaging.MessageAnnotationsAMQPMessageBrokerAccessor.getDecodedMessageAnnotations(AMQPMessage message) static ObjectAMQPMessageBrokerAccessor.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.AckReasonAMQPMessageBrokerAccessor.getMessageAnnotationAckReason(AMQPMessage message) static ObjectAMQPMessageBrokerAccessor.getMessageAnnotationProperty(AMQPMessage message, org.apache.qpid.proton.amqp.Symbol symbol) Warning: this is a method specific to the broker.static intAMQPMessageBrokerAccessor.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 -
Uses of AMQPMessage in org.apache.activemq.artemis.protocol.amqp.connect.federation
Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation that return AMQPMessageModifier and TypeMethodDescriptionstatic AMQPMessageAMQPFederationEventSupport.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 AMQPMessageAMQPFederationPolicySupport.encodeAddressPolicyControlMessage(FederationReceiveFromAddressPolicy policy) Create an AMQP Message used to instruct the remote peer that it should perform Federation operations on the givenFederationReceiveFromAddressPolicy.static AMQPMessageAMQPFederationEventSupport.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 AMQPMessageAMQPFederationPolicySupport.encodeQueuePolicyControlMessage(FederationReceiveFromQueuePolicy policy) Create an AMQP Message used to instruct the remote peer that it should perform Federation operations on the givenFederationReceiveFromQueuePolicy.Methods in org.apache.activemq.artemis.protocol.amqp.connect.federation with parameters of type AMQPMessageModifier and TypeMethodDescriptionAMQPFederationEventSupport.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.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.AMQPFederationPolicySupport.decodeReceiveFromAddressPolicy(AMQPMessage message, WildcardConfiguration wildcardConfig) Given an AMQP Message decode anFederationReceiveFromAddressPolicyfrom it and return the decoded value.AMQPFederationPolicySupport.decodeReceiveFromQueuePolicy(AMQPMessage message, WildcardConfiguration wildcardConfig) Given an AMQP Message decode anFederationReceiveFromQueuePolicyfrom it and return the decoded value.voidAMQPFederationCommandDispatcher.sendCommand(AMQPMessage command) Raw send command that accepts andAMQPMessageinstance and routes it using the server post office instance.voidAMQPFederationEventDispatcher.sendEvent(AMQPMessage event) Raw event send API that accepts anAMQPMessageinstance 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 AMQPMessageMethods in org.apache.activemq.artemis.protocol.amqp.converter that return AMQPMessageModifier and TypeMethodDescriptionstatic AMQPMessageCoreAmqpConverter.checkAMQP(Message message, org.apache.activemq.artemis.core.persistence.StorageManager storageManager) AMQPConverter.fromCore(ICoreMessage coreMessage, org.apache.activemq.artemis.core.persistence.StorageManager storageManager) static AMQPMessageCoreAmqpConverter.fromCore(ICoreMessage coreMessage, org.apache.activemq.artemis.core.persistence.StorageManager storageManager) Methods in org.apache.activemq.artemis.protocol.amqp.converter with parameters of type AMQPMessageModifier and TypeMethodDescriptionAMQPConverter.toCore(AMQPMessage messageSource, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools) static ICoreMessageAmqpCoreConverter.toCore(AMQPMessage message, org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools coreMessageObjectPools) static ICoreMessageAmqpCoreConverter.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)