Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
M
- management() - Element in annotation interface org.springframework.amqp.rabbit.junit.RabbitAvailable
-
Requires the management plugin to be available.
- managementPort() - Static method in class org.springframework.amqp.rabbit.junit.AbstractTestContainerTests
- MANUAL - Enum constant in enum class org.springframework.amqp.core.AcknowledgeMode
-
Manual acks - user must ack/nack via a channel aware listener.
- MapBuilder<B extends MapBuilder<B,
K, V>, K, V> - Class in org.springframework.amqp.utils -
A
Builder
pattern implementation for aMap
. - MapBuilder() - Constructor for class org.springframework.amqp.utils.MapBuilder
- MarshallingMessageConverter - Class in org.springframework.amqp.support.converter
- MarshallingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter
- MarshallingMessageConverter(Marshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter
-
Construct a new
MarshallingMessageConverter
with the givenMarshaller
set. - MarshallingMessageConverter(Marshaller, Unmarshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter
-
Construct a new
MarshallingMessageConverter
with the given Marshaller and Unmarshaller. - match() - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator
- matches(Object) - Method in class org.springframework.amqp.core.BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator
- matchHandlerMethod(Class<? extends Object>, InvocableHandlerMethod) - Method in class org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler
- maxAttempts(int) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
-
Apply the max attempts - a SimpleRetryPolicy will be used.
- maxLength(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the number of (ready) messages allowed in the queue before it starts to drop them.
- maxLengthBytes(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the total aggregate body size allowed in the queue before it starts to drop them.
- maxPriority(int) - Method in class org.springframework.amqp.core.QueueBuilder
-
Set the maximum number if priority levels for the queue to support; if not set, the queue will not support message priorities.
- Message - Class in org.springframework.amqp.core
-
The 0-8 and 0-9-1 AMQP specifications do not define an Message class or interface.
- Message(byte[]) - Constructor for class org.springframework.amqp.core.Message
-
Construct an instance with the provided body and default
MessageProperties
. - Message(byte[], MessageProperties) - Constructor for class org.springframework.amqp.core.Message
-
Construct an instance with the provided body and properties.
- MESSAGE - Static variable in class org.springframework.amqp.support.SendRetryContextAccessor
-
Key for the message we tried to send.
- MESSAGE_COUNT - Static variable in class org.springframework.amqp.support.AmqpHeaders
- MESSAGE_ID - Static variable in class org.springframework.amqp.support.AmqpHeaders
- MessageAckListener - Interface in org.springframework.amqp.rabbit.listener
-
A listener for message ack when using
AcknowledgeMode.AUTO
. - MessageBatch - Class in org.springframework.amqp.rabbit.batch
-
An object encapsulating a
Message
containing the batch of messages, the exchange, and routing key. - MessageBatch(String, String, Message) - Constructor for class org.springframework.amqp.rabbit.batch.MessageBatch
- MessageBatchRecoverer - Interface in org.springframework.amqp.rabbit.retry
-
A retry recoverer for use with a batch listener.
- messageBuilder() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
-
Return the producer's
MessageBuilder
to create native stream messages. - messageBuilder() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- MessageBuilder - Class in org.springframework.amqp.core
-
Builds a Spring AMQP Message either from a byte[] body or another Message using a fluent API.
- MessageBuilderSupport<T> - Class in org.springframework.amqp.core
-
Support class for building
Message
andMessageProperties
fluent API. - MessageBuilderSupport() - Constructor for class org.springframework.amqp.core.MessageBuilderSupport
- MessageBuilderSupport(MessageProperties) - Constructor for class org.springframework.amqp.core.MessageBuilderSupport
- MessageConversionException - Exception in org.springframework.amqp.support.converter
-
Exception to be thrown by message converters if they encounter a problem with converting a message or object.
- MessageConversionException(String) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
- MessageConversionException(String, Throwable) - Constructor for exception org.springframework.amqp.support.converter.MessageConversionException
- messageConverter() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
-
Override the container factory's message converter used for this listener.
- messageConverter() - Method in interface org.springframework.rabbit.stream.producer.RabbitStreamOperations
-
Return the message converter.
- messageConverter() - Method in class org.springframework.rabbit.stream.producer.RabbitStreamTemplate
- MessageConverter - Interface in org.springframework.amqp.support.converter
-
Message converter interface.
- messageCount(String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- MessageDeliveryMode - Enum Class in org.springframework.amqp.core
-
Enumeration for the message delivery mode.
- messageKeyGenerator(MessageKeyGenerator) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
-
Stateful retry requires messages to be identifiable.
- MessageKeyGenerator - Interface in org.springframework.amqp.rabbit.retry
- MessageListener - Interface in org.springframework.amqp.core
-
Listener interface to receive asynchronous delivery of Amqp Messages.
- MessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
Message listener adapter that delegates the handling of messages to target listener methods via reflection, with flexible message type conversion.
- MessageListenerAdapter() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
with default settings. - MessageListenerAdapter(Object) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
for the given delegate. - MessageListenerAdapter(Object, String) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
for the given delegate while also declaring its POJO method. - MessageListenerAdapter(Object, MessageConverter) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Create a new
MessageListenerAdapter
for the given delegate. - MessageListenerContainer - Interface in org.springframework.amqp.rabbit.listener
-
Internal abstraction used by the framework representing a message listener container.
- MessagePostProcessor - Interface in org.springframework.amqp.core
-
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 - Class in org.springframework.amqp.support.postprocessor
-
Utilities for message post processors.
- MessageProperties - Class in org.springframework.amqp.core
-
Message Properties for an AMQP message.
- MessageProperties() - Constructor for class org.springframework.amqp.core.MessageProperties
- MessagePropertiesBuilder - Class in org.springframework.amqp.core
-
Builds a Spring AMQP MessageProperties object using a fluent API.
- MessagePropertiesConverter - Interface in org.springframework.amqp.rabbit.support
-
Strategy interface for converting between Spring AMQP
MessageProperties
and RabbitMQ BasicProperties. - MessageRecoverer - Interface in org.springframework.amqp.rabbit.retry
-
Implementations of this interface can handle failed messages after retries are exhausted.
- MessageRejectedWhileStoppingException - Exception in org.springframework.amqp.rabbit.listener.exception
-
Exception class that indicates a rejected message on shutdown.
- MessageRejectedWhileStoppingException() - Constructor for exception org.springframework.amqp.rabbit.listener.exception.MessageRejectedWhileStoppingException
- MessagingMessageConverter - Class in org.springframework.amqp.support.converter
-
Convert a
Message
from the messaging abstraction to and from aMessage
using an underlyingMessageConverter
for the payload and aAmqpHeaderMapper
to map the AMQP headers to and from standard message headers. - MessagingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.MessagingMessageConverter
-
Create an instance with a default payload converter for an inbound handler.
- MessagingMessageConverter(MessageConverter, AmqpHeaderMapper) - Constructor for class org.springframework.amqp.support.converter.MessagingMessageConverter
-
Create an instance with the specified payload converter and header mapper.
- MessagingMessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
A
MessageListener
adapter that invokes a configurableHandlerAdapter
. - MessagingMessageListenerAdapter() - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter(Object, Method) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter(Object, Method, boolean, RabbitListenerErrorHandler) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter(Object, Method, boolean, RabbitListenerErrorHandler, boolean) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
- MessagingMessageListenerAdapter.MessagingMessageConverterAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
Delegates payload extraction to
AbstractAdaptableMessageListener.extractMessage(org.springframework.amqp.core.Message message)
to enforce backward compatibility. - METHOD_ATTRIBUTE - Static variable in class org.springframework.amqp.rabbit.config.NamespaceUtils
- MethodRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener
-
A
RabbitListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint. - MethodRabbitListenerEndpoint() - Constructor for class org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint
- MethodRabbitListenerEndpoint.AdapterProvider - Interface in org.springframework.amqp.rabbit.listener
-
Provider of listener adapters.
- MicrometerHolder - Class in org.springframework.amqp.rabbit.listener
-
Abstraction to avoid hard reference to Micrometer.
- minLeaders - Enum constant in enum class org.springframework.amqp.core.QueueBuilder.LeaderLocator
-
Deploy on the node with the fewest queue leaders.
- MissingQueueEvent - Class in org.springframework.amqp.rabbit.listener
-
Event published when a missing queue is detected.
- MissingQueueEvent(Object, String) - Constructor for class org.springframework.amqp.rabbit.listener.MissingQueueEvent
-
Construct an instance with the provided source and queue.
- MULTI_RABBIT_ADMIN_SUFFIX - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
-
The MultiRabbit admins' suffix.
- MULTI_RABBIT_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
-
The bean name of the ContainerFactory of the default broker for MultiRabbit.
- MULTI_RABBIT_ENABLED_PROPERTY - Static variable in class org.springframework.amqp.rabbit.config.RabbitListenerConfigUtils
-
The default property to enable/disable MultiRabbit processing.
- MultiMethodRabbitListenerEndpoint - Class in org.springframework.amqp.rabbit.listener
- MultiMethodRabbitListenerEndpoint(List<Method>, Method, Object) - Constructor for class org.springframework.amqp.rabbit.listener.MultiMethodRabbitListenerEndpoint
-
Construct an instance for the provided methods, default method and bean.
- MultiRabbitBootstrapConfiguration - Class in org.springframework.amqp.rabbit.annotation
-
An
ImportBeanDefinitionRegistrar
class that registers aMultiRabbitListenerAnnotationBeanPostProcessor
bean, if MultiRabbit is enabled. - MultiRabbitBootstrapConfiguration() - Constructor for class org.springframework.amqp.rabbit.annotation.MultiRabbitBootstrapConfiguration
- MultiRabbitListenerAnnotationBeanPostProcessor - Class in org.springframework.amqp.rabbit.annotation
-
An extension of
RabbitListenerAnnotationBeanPostProcessor
that indicates the proper RabbitAdmin bean to be used when processing to the listeners, and also associates it to the declarables (Exchanges, Queues, and Bindings) returned. - MultiRabbitListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.amqp.rabbit.annotation.MultiRabbitListenerAnnotationBeanPostProcessor
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form