Index

A B C D E F G H I J K L M N O P Q R S T U V W X Z _
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 a Map.

MapBuilder() - Constructor for class org.springframework.amqp.utils.MapBuilder

MarshallingMessageConverter - Class in org.springframework.amqp.support.converter

Spring Rabbit MessageConverter that uses a Marshaller and Unmarshaller.

MarshallingMessageConverter() - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter

Construct a new MarshallingMessageConverter with no Marshaller or Unmarshaller set.

MarshallingMessageConverter(Marshaller) - Constructor for class org.springframework.amqp.support.converter.MarshallingMessageConverter

Construct a new MarshallingMessageConverter with the given Marshaller 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

maxAge(String) - Method in class org.springframework.rabbit.stream.config.SuperStreamBuilder

Set the maximum age retention per stream, which will remove the oldest data.

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

Deprecated.

in favor of QueueBuilder.maxLength(long).

maxLength(long) - Method in class org.springframework.amqp.core.QueueBuilder

Set the number of (ready) messages allowed in the queue before it starts to drop them.

maxLength(long) - Method in class org.springframework.rabbit.stream.config.SuperStreamBuilder

Set the maximum log size as the retention configuration for each stream, which will truncate the log based on the data size.

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.

maxSegmentSize(long) - Method in class org.springframework.rabbit.stream.config.SuperStreamBuilder

Set the maximum size limit for segment file.

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 and MessageProperties 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 a Message using an underlying MessageConverter for the payload and a AmqpHeaderMapper 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 configurable HandlerAdapter.

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 a MultiRabbitListenerAnnotationBeanPostProcessor 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

A B C D E F G H I J K L M N O P Q R S T U V W X Z _
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form