Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
B
- backOffOptions(long, double, long) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
-
Apply the backoff options.
- backOffPolicy(BackOffPolicy) - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
-
Apply the back off policy.
- BASE_PACKAGE - Static variable in class org.springframework.amqp.rabbit.config.NamespaceUtils
- Base64UrlNamingStrategy - Class in org.springframework.amqp.core
-
Generates names with the form
<prefix><base64url>
where 'prefix' is 'spring.gen-' by default (e.g. - Base64UrlNamingStrategy() - Constructor for class org.springframework.amqp.core.Base64UrlNamingStrategy
-
Construct an instance using the default prefix
spring.gen-
. - Base64UrlNamingStrategy(String) - Constructor for class org.springframework.amqp.core.Base64UrlNamingStrategy
-
Construct an instance using the supplied prefix.
- BaseRabbitListenerContainerFactory<C extends MessageListenerContainer> - Class in org.springframework.amqp.rabbit.config
-
Base abstract class for listener container factories.
- BaseRabbitListenerContainerFactory() - Constructor for class org.springframework.amqp.rabbit.config.BaseRabbitListenerContainerFactory
- BASIC_CLASS_ID_60 - Static variable in class org.springframework.amqp.rabbit.connection.RabbitUtils
-
AMQP basic class id.
- basicAck(long, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicCancel() - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- basicCancel(boolean) - Method in class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
- basicCancel(String) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, boolean, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, boolean, String, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, Map<String, Object>, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 3.3.x client.
- basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, Map<String, Object>, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, boolean, Map<String, Object>, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, Consumer) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicConsume(String, DeliverCallback, CancelCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 5.0.x client.
- basicGet(String, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicNack(long, boolean, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicPublish(String, String, boolean, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicPublish(String, String, AMQP.BasicProperties, byte[]) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicQos(int) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicQos(int, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
-
Added to the 3.3.x client.
- basicQos(int, int, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicRecover() - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicRecover(boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- basicReject(long, boolean) - Method in class org.springframework.amqp.rabbit.connection.PublisherCallbackChannelImpl
- batch() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
-
Override the container factory's
batchListener
property. - BATCH_FORMAT_LENGTH_HEADER4 - Static variable in class org.springframework.amqp.core.MessageProperties
- BATCH_SIZE - Static variable in class org.springframework.amqp.support.AmqpHeaders
-
The number of fragments in a batch message.
- BatchingRabbitTemplate - Class in org.springframework.amqp.rabbit.core
-
A
RabbitTemplate
that permits batching individual messages into a larger message. - BatchingRabbitTemplate(BatchingStrategy, TaskScheduler) - Constructor for class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
-
Create an instance with the supplied parameters.
- BatchingRabbitTemplate(ConnectionFactory, BatchingStrategy, TaskScheduler) - Constructor for class org.springframework.amqp.rabbit.core.BatchingRabbitTemplate
-
Create an instance with the supplied parameters.
- BatchingStrategy - Interface in org.springframework.amqp.rabbit.batch
-
Strategy for batching messages.
- BatchMessageListener - Interface in org.springframework.amqp.core
-
Used to receive a batch of messages if the container supports it.
- BatchMessagingMessageListenerAdapter - Class in org.springframework.amqp.rabbit.listener.adapter
-
A listener adapter for batch listeners.
- BatchMessagingMessageListenerAdapter(Object, Method, boolean, RabbitListenerErrorHandler, BatchingStrategy) - Constructor for class org.springframework.amqp.rabbit.listener.adapter.BatchMessagingMessageListenerAdapter
- BEAN_NAME - Enum constant in enum class org.springframework.amqp.rabbit.support.micrometer.RabbitTemplateObservation.TemplateLowCardinalityTags
-
Bean name of the template.
- BEAN_NAME - Enum constant in enum class org.springframework.rabbit.stream.micrometer.RabbitStreamTemplateObservation.TemplateLowCardinalityTags
-
Bean name of the template.
- beforeAll(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- beforeEach(ExtensionContext) - Method in class org.springframework.amqp.rabbit.junit.LogLevelsCondition
- bind(Object, Object) - Static method in class org.springframework.amqp.rabbit.connection.SimpleResourceHolder
-
Bind the given resource for the given key to the current thread.
- bind(Exchange) - Static method in class org.springframework.amqp.core.BindingBuilder
- bind(Queue) - Static method in class org.springframework.amqp.core.BindingBuilder
- Binding - Class in org.springframework.amqp.core
-
Simple container collecting information to describe a binding.
- Binding(String, Binding.DestinationType, String, String, Map<String, Object>) - Constructor for class org.springframework.amqp.core.Binding
- Binding(Queue, String, Binding.DestinationType, String, String, Map<String, Object>) - Constructor for class org.springframework.amqp.core.Binding
- BINDING_ARGUMENTS - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- BINDING_EXCHANGE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- BINDING_QUEUE_ATTR - Static variable in class org.springframework.amqp.rabbit.config.AbstractExchangeParser
- Binding.DestinationType - Enum Class in org.springframework.amqp.core
-
The binding destination.
- BindingBuilder - Class in org.springframework.amqp.core
-
Basic builder class to create bindings for a more fluent API style in code based configuration.
- BindingBuilder.DestinationConfigurer - Class in org.springframework.amqp.core
-
General destination configurer.
- BindingBuilder.DirectExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
-
Direct exchange routing key configurer.
- BindingBuilder.GenericArgumentsConfigurer - Class in org.springframework.amqp.core
-
Generic argument configurer.
- BindingBuilder.GenericExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
-
Generic exchange routing key configurer.
- BindingBuilder.HeadersExchangeMapConfigurer - Class in org.springframework.amqp.core
-
Headers exchange configurer.
- BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeKeysBindingCreator - Class in org.springframework.amqp.core
-
Headers exchange keys binding creator.
- BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeMapBindingCreator - Class in org.springframework.amqp.core
-
Headers exchange map binding creator.
- BindingBuilder.HeadersExchangeMapConfigurer.HeadersExchangeSingleValueBindingCreator - Class in org.springframework.amqp.core
-
Headers exchange single value binding creator.
- BindingBuilder.TopicExchangeRoutingKeyConfigurer - Class in org.springframework.amqp.core
-
Topic exchange routing key configurer.
- BindingFactoryBean - Class in org.springframework.amqp.rabbit.config
- BindingFactoryBean() - Constructor for class org.springframework.amqp.rabbit.config.BindingFactoryBean
- bindings() - Element in annotation interface org.springframework.amqp.rabbit.annotation.RabbitListener
-
Array of
QueueBinding
s providing the listener's queue names, together with the exchange and optional binding information. - bindResourceToTransaction(RabbitResourceHolder, ConnectionFactory, boolean) - Static method in class org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils
- BlockingQueueConsumer - Class in org.springframework.amqp.rabbit.listener
-
Specialized consumer encapsulating knowledge of the broker connections and having its own lifecycle (start and stop).
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, boolean, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, boolean, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, boolean, Map<String, Object>, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BlockingQueueConsumer(ConnectionFactory, MessagePropertiesConverter, ActiveObjectCounter<BlockingQueueConsumer>, AcknowledgeMode, boolean, int, String...) - Constructor for class org.springframework.amqp.rabbit.listener.BlockingQueueConsumer
-
Create a consumer.
- BROKER_ADMIN_PW - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_ADMIN_URI - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_ADMIN_USER - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_HOSTNAME - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_PORT - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_PW - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_REQUIRED - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BROKER_USER - Static variable in class org.springframework.amqp.rabbit.junit.BrokerRunningSupport
- BrokerEvent - Class in org.springframework.amqp.rabbit.core
-
Represents a broker event generated by the Event Exchange Plugin (https://www.rabbitmq.com/event-exchange.html).
- BrokerEvent(Object, MessageProperties) - Constructor for class org.springframework.amqp.rabbit.core.BrokerEvent
-
Create an instance with the provided source and properties.
- BrokerEventListener - Class in org.springframework.amqp.rabbit.core
-
When the event-exchange-plugin is enabled (see https://www.rabbitmq.com/event-exchange.html), if an object of this type is declared as a bean, selected events will be published as
BrokerEvent
s. - BrokerEventListener(ConnectionFactory, String...) - Constructor for class org.springframework.amqp.rabbit.core.BrokerEventListener
-
Construct an instance using the supplied connection factory and event keys.
- BrokerEventListener(AbstractMessageListenerContainer, String...) - Constructor for class org.springframework.amqp.rabbit.core.BrokerEventListener
-
Construct an instance using the supplied listener container factory and event keys.
- BrokerRunning - Class in org.springframework.amqp.rabbit.junit
-
A rule that prevents integration tests from failing if the Rabbit broker application is not running or not accessible.
- BrokerRunningSupport - Class in org.springframework.amqp.rabbit.junit
-
A class that can be used to prevent integration tests from failing if the Rabbit broker application is not running or not accessible.
- BrokerRunningSupport.BrokerNotAliveException - Exception in org.springframework.amqp.rabbit.junit
-
The
RuntimeException
thrown when broker is not available on the provided host port. - BrokerTestUtils - Class in org.springframework.amqp.rabbit.junit
-
Global convenience class for all integration tests, carrying constants and other utilities for broker set up.
- build() - Method in class org.springframework.amqp.core.ExchangeBuilder
- build() - Method in class org.springframework.amqp.core.MessageBuilder
- build() - Method in class org.springframework.amqp.core.MessageBuilderSupport
- build() - Method in class org.springframework.amqp.core.MessagePropertiesBuilder
- build() - Method in class org.springframework.amqp.core.QueueBuilder
-
Builds a final queue.
- build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder
- build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatefulRetryInterceptorBuilder
- build() - Method in class org.springframework.amqp.rabbit.config.RetryInterceptorBuilder.StatelessRetryInterceptorBuilder
- build() - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Builder
- build() - Method in class org.springframework.rabbit.stream.config.SuperStreamBuilder
-
Builds a final Super Stream.
- Builder() - Constructor for class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Builder
- buildInstance(String, Filter, Layout<? extends Serializable>, boolean, AmqpAppender.AmqpManager, BlockingQueue<AmqpAppender.Event>) - Method in class org.springframework.amqp.rabbit.log4j2.AmqpAppender.Builder
-
Subclasses can extends Builder, use same logic but need to modify class instance.
- buildListenerArguments(Object, Channel, Message) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter
-
Build an array of arguments to be passed into the target listener method.
- buildMessage(Channel, Object, Type) - Method in class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener
-
Build a Rabbit message to be sent as response based on the given result object.
- buildMessage(Channel, Object, Type) - Method in class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter
-
Build a Rabbit message to be sent as response based on the given result object.
- buildProperties() - Method in class org.springframework.amqp.core.MessageBuilderSupport
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form