Provides core classes for Spring Rabbit.
Interface Summary Interface Description ChannelCallback<T>Basic callback for use in RabbitTemplate. CorrelationDataPostProcessorA callback invoked immediately before publishing a message to update, replace, or create correlation data for publisher confirms. RabbitMessageOperations RabbitOperationsRabbit specific methods for Amqp functionality. RabbitOperations.OperationsCallback<T>Callback for using the same channel for multiple RabbitTemplate operations. RabbitTemplate.ConfirmCallbackA callback for publisher confirmations. RabbitTemplate.ReturnCallback Deprecated.in favor of
RabbitTemplate.ReturnCallback.returnedMessage(ReturnedMessage)which is easier to use with lambdas.
RabbitTemplate.ReturnsCallbackA callback for returned messages.
Class Summary Class Description BatchingRabbitTemplateA
RabbitTemplatethat permits batching individual messages into a larger message.
BrokerEventRepresents a broker event generated by the Event Exchange Plugin (https://www.rabbitmq.com/event-exchange.html). BrokerEventListenerWhen 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
DeclarationExceptionEventApplication event published when a declaration exception occurs. DeclareExchangeConnectionListenerA
ConnectionListenerthat will declare a single exchange when the connection is established.
RabbitAdminRabbitMQ implementation of portable AMQP administrative operations for AMQP >= 0.9.1. RabbitAdminEventBase class for admin events. RabbitGatewaySupportConvenient super class for application classes that need RabbitMQ access. RabbitMessagingTemplateAn implementation of
RabbitTemplateHelper class that simplifies synchronous RabbitMQ access (sending and receiving messages). RabbitTemplate.TemplateConsumerAdds
Exception Summary Exception Description AmqpNackReceivedExceptionAn exception thrown when a negative acknowledgement received after publishing a message. ConsumeOkNotReceivedExceptionThrown when a blocking receive operation is performed but the consumeOk was not received before the receive timeout.