Package org.springframework.amqp.core
Provides core classes for the spring AMQP abstraction.
-
Interface Summary Interface Description AmqpAdmin Specifies a basic set of portable AMQP administrative operations for AMQP > 0.9.AmqpTemplate Specifies a basic set of AMQP operations.AsyncAmqpTemplate Classes implementing this interface can perform asynchronous send and receive operations.BatchMessageListener Used to receive a batch of messages if the container supports it.Correlation A marker interface for data used to correlate information about sent messages.Declarable Classes implementing this interface can be auto-declared with the broker during context initialization by anAmqpAdmin
.DeclarableCustomizer Beans of this type are invoked by theAmqpAdmin
before declaring theDeclarable
, allowing customization thereof.Exchange Interface for all exchanges.MessageListener Listener interface to receive asynchronous delivery of Amqp Messages.MessagePostProcessor Used in several places in the framework, such asAmqpTemplate#convertAndSend(Object, MessagePostProcessor)
where it can be used to add/modify headers or properties after the message conversion has been performed.NamingStrategy A strategy to generate names.ReceiveAndReplyCallback<R,S> To be used with the receive-and-reply methods ofAmqpTemplate
as processor for inbound object and producer for outbound object.ReceiveAndReplyMessageCallback Message
exchanging contract ofReceiveAndReplyCallback
.ReplyToAddressCallback<T> To be used with the receive-and-reply methods ofAmqpTemplate
to determineAddress
forMessage
to send at runtime. -
Class Summary Class Description AbstractBuilder Base class for builders supporting arguments.AbstractDeclarable Base class forDeclarable
classes.AbstractExchange Common properties that describe all exchange types.Address Represents an address for publication of an AMQP message.AnonymousQueue Represents an anonymous, non-durable, exclusive, auto-delete queue.Base64UrlNamingStrategy Generates names with the form<prefix><base64url>
where 'prefix' is 'spring.gen-' by default (e.g.Binding Simple container collecting information to describe a binding.BindingBuilder Basic builder class to create bindings for a more fluent API style in code based configuration.BindingBuilder.DestinationConfigurer General destination configurer.BindingBuilder.DirectExchangeRoutingKeyConfigurer Direct exchange routing key configurer.BindingBuilder.GenericArgumentsConfigurer Generic argument configurer.BindingBuilder.GenericExchangeRoutingKeyConfigurer Generic exchange routing key configurer.BindingBuilder.HeadersExchangeMapConfigurer Headers exchange configurer.BindingBuilder.TopicExchangeRoutingKeyConfigurer Topic exchange routing key configurer.CustomExchange Simple container collecting information to describe a custom exchange.Declarables A collection ofDeclarable
objects; used to declare multiple objects on the broker using a single bean declaration for the collection.DirectExchange Simple container collecting information to describe a direct exchange.ExchangeBuilder Builder providing a fluent API for buildingExchange
s.ExchangeTypes Constants for the standard Exchange type names.FanoutExchange Simple container collecting information to describe a fanout exchange.HeadersExchange Headers exchange.Message The 0-8 and 0-9-1 AMQP specifications do not define an Message class or interface.MessageBuilder Builds a Spring AMQP Message either from a byte[] body or another Message using a fluent API.MessageBuilderSupport<T> Support class for buildingMessage
andMessageProperties
fluent API.MessageProperties Message Properties for an AMQP message.MessagePropertiesBuilder Builds a Spring AMQP MessageProperties object using a fluent API.Queue Simple container collecting information to describe a queue.QueueBuilder Builds a Spring AMQP Queue using a fluent API.QueueInformation Information about a queue, resulting from a passive declaration.ReturnedMessage Returned message and its metadata.TopicExchange Simple container collecting information to describe a topic exchange.UUIDNamingStrategy Generates names usingUUID.randomUUID()
. -
Enum Summary Enum Description AcknowledgeMode Acknowledgment modes supported by the listener container.Binding.DestinationType The binding destination.MessageDeliveryMode Enumeration for the message delivery mode.QueueBuilder.LeaderLocator Locate the queue leader.QueueBuilder.MasterLocator Deprecated. in favor ofQueueBuilder.LeaderLocator
.QueueBuilder.Overflow Overflow argument values. -
Exception Summary Exception Description AmqpMessageReturnedException Exception thrown if the request message cannot be delivered when the mandatory flag is set.AmqpReplyTimeoutException Async reply timeout.