All Classes Interface Summary Class Summary Enum Summary Exception Summary
| Class |
Description |
| AbstractBuilder |
Base class for builders supporting arguments.
|
| AbstractCompressingPostProcessor |
Base class for post processors that compress the message body.
|
| AbstractDeclarable |
|
| AbstractDecompressingPostProcessor |
|
| AbstractDeflaterPostProcessor |
Base class for post processors based on Deflater.
|
| AbstractExchange |
Common properties that describe all exchange types.
|
| AbstractJackson2MessageConverter |
Abstract Jackson2 message converter.
|
| AbstractJavaTypeMapper |
Abstract type mapper.
|
| AbstractMessageConverter |
|
| AcknowledgeMode |
Acknowledgment modes supported by the listener container.
|
| Address |
Represents an address for publication of an AMQP message.
|
| AllowedListDeserializingMessageConverter |
MessageConverters that potentially use Java deserialization.
|
| AmqpAdmin |
Specifies a basic set of portable AMQP administrative operations for AMQP > 0.9.
|
| AmqpApplicationContextClosedException |
Thrown when the connection factory has been destroyed during
context close; the factory can no longer open connections.
|
| AmqpAuthenticationException |
Runtime wrapper for an authentication exception.
|
| AmqpClientInterceptor |
Deprecated.
|
| AmqpConnectException |
RuntimeException wrapper for an ConnectException which can be commonly
thrown from AMQP operations if the remote process dies or there is a network issue.
|
| AmqpEvent |
Base class for events.
|
| AmqpException |
Base RuntimeException for errors that occur when executing AMQP operations.
|
| AmqpHeaderMapper |
Strategy interface for mapping messaging Message headers to an outbound
MessageProperties (e.g.
|
| AmqpHeaders |
Pre-defined names and prefixes to be used for setting and/or retrieving AMQP
MessageProperties from/to Message Headers.
|
| AmqpIllegalStateException |
Equivalent of an IllegalStateException but within the AmqpException hierarchy.
|
| AmqpInvokerServiceExporter |
Deprecated.
|
| AmqpIOException |
RuntimeException wrapper for an IOException which
can be commonly thrown from AMQP operations.
|
| AmqpMessageHeaderAccessor |
A MessageHeaderAccessor
implementation giving access to AMQP-specific headers.
|
| AmqpMessageReturnedException |
Exception thrown if the request message cannot be delivered when the mandatory flag is
set.
|
| AmqpProxyFactoryBean |
Deprecated.
|
| AmqpRejectAndDontRequeueException |
Exception for listener implementations used to indicate the
basic.reject will be sent with requeue=false in order to enable
features such as DLQ.
|
| AmqpRemoteException |
An exception that wraps an exception thrown by the server in a
request/reply scenario.
|
| AmqpReplyTimeoutException |
Async reply timeout.
|
| AmqpResourceNotAvailableException |
|
| AmqpTemplate |
Specifies a basic set of AMQP operations.
|
| AmqpTimeoutException |
Exception thrown when some time-bound operation fails to execute in the
desired time.
|
| AmqpUnsupportedEncodingException |
RuntimeException for unsupported encoding in an AMQP operation.
|
| AnonymousQueue |
Represents an anonymous, non-durable, exclusive, auto-delete queue.
|
| AsyncAmqpTemplate |
Classes implementing this interface can perform asynchronous send and
receive operations.
|
| Base64UrlNamingStrategy |
Generates names with the form <prefix><base64url> where 'prefix' is
'spring.gen-' by default (e.g.
|
| BatchMessageListener |
Used to receive a batch of messages if the container supports it.
|
| Binding |
Simple container collecting information to describe a binding.
|
| Binding.DestinationType |
The binding destination.
|
| 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.
|
| ClassMapper |
Strategy for setting metadata on messages such that one can create the class
that needs to be instantiated when receiving a message.
|
| ConditionalExceptionLogger |
For components that support customization of the logging of certain events, users can
provide an implementation of this interface to modify the existing logging behavior.
|
| ConsumerTagStrategy |
A strategy interface to determine the consumer tag to be used when issuing a
basicConsume operation.
|
| ContentTypeDelegatingMessageConverter |
|
| Correlation |
A marker interface for data used to correlate information about sent messages.
|
| CustomExchange |
Simple container collecting information to describe a custom exchange.
|
| Declarable |
Classes implementing this interface can be auto-declared
with the broker during context initialization by an AmqpAdmin.
|
| DeclarableCustomizer |
Beans of this type are invoked by the AmqpAdmin before declaring the
Declarable, allowing customization thereof.
|
| Declarables |
A collection of Declarable objects; used to declare multiple objects on the
broker using a single bean declaration for the collection.
|
| DefaultClassMapper |
|
| DefaultJackson2JavaTypeMapper |
Jackson 2 type mapper.
|
| DeflaterPostProcessor |
A post processor that uses a DeflaterOutputStream to compress the message body.
|
| DelegatingDecompressingPostProcessor |
|
| DirectExchange |
Simple container collecting information to describe a direct exchange.
|
| Exchange |
Interface for all exchanges.
|
| ExchangeBuilder |
Builder providing a fluent API for building Exchanges.
|
| ExchangeTypes |
Constants for the standard Exchange type names.
|
| FanoutExchange |
Simple container collecting information to describe a fanout exchange.
|
| GUnzipPostProcessor |
A post processor that uses a GZIPInputStream to decompress the
message body.
|
| GZipPostProcessor |
A post processor that uses a GZIPOutputStream to compress the message body.
|
| HeadersExchange |
Headers exchange.
|
| ImmediateAcknowledgeAmqpException |
Special exception for listener implementations that want to signal that the current
batch of messages should be acknowledged immediately (i.e.
|
| ImmediateRequeueAmqpException |
|
| InflaterPostProcessor |
A post processor that uses a InflaterInputStream to decompress the
message body.
|
| Jackson2JavaTypeMapper |
Strategy for setting metadata on messages such that one can create the class that needs
to be instantiated when receiving a message.
|
| Jackson2JavaTypeMapper.TypePrecedence |
The precedence for type conversion - inferred from the method parameter or message
headers.
|
| Jackson2JsonMessageConverter |
JSON converter that uses the Jackson 2 Json library.
|
| Jackson2XmlMessageConverter |
XML converter that uses the Jackson 2 Xml library.
|
| JavaUtils |
Chained utility methods to simplify some Java repetitive code.
|
| MapBuilder<B extends MapBuilder<B,K,V>,K,V> |
A Builder pattern implementation for a Map.
|
| MarshallingMessageConverter |
|
| 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> |
|
| MessageConversionException |
Exception to be thrown by message converters if they encounter a problem with converting a message or object.
|
| MessageConverter |
Message converter interface.
|
| MessageDeliveryMode |
Enumeration for the message delivery mode.
|
| MessageListener |
Listener interface to receive asynchronous delivery of Amqp Messages.
|
| MessagePostProcessor |
Used in several places in the framework, such as
AmqpTemplate#convertAndSend(Object, MessagePostProcessor) where it can be used
to add/modify headers or properties after the message conversion has been performed.
|
| MessagePostProcessorUtils |
Utilities for message post processors.
|
| MessageProperties |
Message Properties for an AMQP message.
|
| MessagePropertiesBuilder |
Builds a Spring AMQP MessageProperties object using a fluent API.
|
| MessagingMessageConverter |
Convert a Message from the messaging abstraction to and from a
Message using an underlying
MessageConverter for the payload and a
AmqpHeaderMapper to map the
AMQP headers to and from standard message headers.
|
| NamingStrategy |
A strategy to generate names.
|
| ProjectingMessageConverter |
Uses a Spring Data ProjectionFactory to bind incoming messages to projection
interfaces.
|
| Queue |
Simple container collecting information to describe a queue.
|
| QueueBuilder |
Builds a Spring AMQP Queue using a fluent API.
|
| QueueBuilder.LeaderLocator |
Locate the queue leader.
|
| QueueBuilder.MasterLocator |
Deprecated.
|
| QueueBuilder.Overflow |
Overflow argument values.
|
| QueueInformation |
Information about a queue, resulting from a passive declaration.
|
| ReceiveAndReplyCallback<R,S> |
To be used with the receive-and-reply methods of AmqpTemplate
as processor for inbound object and producer for outbound object.
|
| ReceiveAndReplyMessageCallback |
|
| RemoteInvocationAwareMessageConverterAdapter |
A delegating adapter that unwraps RemoteInvocationResult after invoking
the delegate to convert from a message.
|
| ReplyToAddressCallback<T> |
|
| ReturnedMessage |
Returned message and its metadata.
|
| SendRetryContextAccessor |
Type safe accessor for retried message sending.
|
| SerializationUtils |
Static utility to help with serialization.
|
| SerializerMessageConverter |
Implementation of MessageConverter that can work with Strings or native objects
of any kind via the Serializer and Deserializer abstractions in Spring.
|
| SimpleAmqpHeaderMapper |
|
| SimpleMessageConverter |
Implementation of MessageConverter that can work with Strings, Serializable
instances, or byte arrays.
|
| SmartMessageConverter |
|
| TestUtils |
See Spring Integration TestUtils.
|
| TopicExchange |
Simple container collecting information to describe a topic exchange.
|
| UncategorizedAmqpException |
A "catch-all" exception type within the AmqpException hierarchy
when no more specific cause is known.
|
| UnzipPostProcessor |
A post processor that uses a ZipInputStream to decompress the
message body.
|
| UUIDNamingStrategy |
Generates names using UUID.randomUUID().
|
| ZipPostProcessor |
A post processor that uses a ZipOutputStream to compress the message body.
|