Package org.springframework.amqp.core
package org.springframework.amqp.core
Provides core classes for the spring AMQP abstraction.
-
ClassDescriptionBase class for builders supporting arguments.Base class for
Declarable
classes.Common properties that describe all exchange types.Acknowledgment modes supported by the listener container.Represents an address for publication of an AMQP message.Specifies a basic set of portable AMQP administrative operations for AMQP > 0.9.Exception thrown if the request message cannot be delivered when the mandatory flag is set.Async reply timeout.Specifies a basic set of AMQP operations.Represents an anonymous, non-durable, exclusive, auto-delete queue.Classes implementing this interface can perform asynchronous send and receive operations usingCompletableFuture
s.Generates names with the form<prefix><base64url>
where 'prefix' is 'spring.gen-' by default (e.g.BaseExchangeBuilder<B extends BaseExchangeBuilder<B>>AnAbstractBuilder
extension for generics support.Used to receive a batch of messages if the container supports it.Simple container collecting information to describe a binding.The binding destination.Basic builder class to create bindings for a more fluent API style in code based configuration.General destination configurer.Direct exchange routing key configurer.Generic argument configurer.Generic exchange routing key configurer.Headers exchange configurer.Topic exchange routing key configurer.AnAbstractExchange
extension for Consistent Hash exchange type.A marker interface for data used to correlate information about sent messages.Simple container collecting information to describe a custom exchange.Classes implementing this interface can be auto-declared with the broker during context initialization by anAmqpAdmin
.Beans of this type are invoked by theAmqpAdmin
before declaring theDeclarable
, allowing customization thereof.A collection ofDeclarable
objects; used to declare multiple objects on the broker using a single bean declaration for the collection.Simple container collecting information to describe a direct exchange.Interface for all exchanges.Builder providing a fluent API for buildingExchange
s.AnExchangeBuilder
extension for theConsistentHashExchange
.Constants for the standard Exchange type names.Simple container collecting information to describe a fanout exchange.Headers exchange.The 0-8 and 0-9-1 AMQP specifications do not define an Message class or interface.Builds a Spring AMQP Message either from a byte[] body or another Message using a fluent API.Support class for buildingMessage
andMessageProperties
fluent API.Enumeration for the message delivery mode.Listener interface to receive asynchronous delivery of Amqp Messages.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.Message Properties for an AMQP message.Builds a Spring AMQP MessageProperties object using a fluent API.A strategy to generate names.Simple container collecting information to describe a queue.Builds a Spring AMQP Queue using a fluent API.Locate the queue leader.Overflow argument values.Information about a queue, resulting from a passive declaration.To be used with the receive-and-reply methods ofAmqpTemplate
as processor for inbound object and producer for outbound object.Message
exchanging contract ofReceiveAndReplyCallback
.To be used with the receive-and-reply methods ofAmqpTemplate
to determineAddress
forMessage
to send at runtime.Returned message and its metadata.Simple container collecting information to describe a topic exchange.Generates names usingUUID.randomUUID()
.