| Interface | Description |
|---|---|
| ChannelPool |
Contract to obtain a
Channel and close when sending messages. |
| Utils.ExceptionFunction<T,R> |
| Class | Description |
|---|---|
| AcknowledgableDelivery |
A RabbitMQ
Delivery that can be manually acknowledged or rejected. |
| BindingSpecification |
Fluent API to specify the binding between AMQP resources.
|
| ChannelCloseHandlers |
Helper class to close channels.
|
| ChannelCloseHandlers.SenderChannelCloseHandler |
Default closing strategy in
Sender. |
| ChannelPoolFactory |
Factory to create default
ChannelPool instances. |
| ChannelPoolOptions |
Options to when creating a
ChannelPool. |
| ChannelProxy |
A
Channel proxy that re-open the underlying channel if necessary. |
| ConsumeOptions |
Options for
Receiver#consume* methods. |
| CorrelableOutboundMessage<T> |
An outbound message meant to be sent by a
Sender and may contain (unserialized)
correlated metadata. |
| ExceptionHandlers | |
| ExceptionHandlers.ConnectionRecoveryTriggeringPredicate | |
| ExceptionHandlers.ExceptionPredicate | |
| ExceptionHandlers.RetryAcknowledgmentExceptionHandler | |
| ExceptionHandlers.RetrySendingExceptionHandler | |
| ExceptionHandlers.SimpleRetryTemplate | |
| ExchangeSpecification |
Fluent API to specify creation of an exchange.
|
| IdempotentClosedConnection |
Implement
Connection that ensure closing is idempotent. |
| OutboundMessage |
Outbound message meant to be sent by a
Sender. |
| OutboundMessageResult<OMSG extends OutboundMessage> |
Result of a sent message when using publisher confirm.
|
| QueueSpecification |
Fluent API to specify the creation of a queue.
|
| RabbitFlux | |
| Receiver |
Reactive abstraction to consume messages as a
Flux. |
| Receiver.AcknowledgmentContext | |
| ReceiverOptions |
Options for
Receiver creation. |
| ResourceManagementOptions |
Options for resource management in
Sender. |
| ResourcesSpecification | |
| RpcClient | |
| RpcClient.RpcRequest | |
| Sender |
Reactive abstraction to create resources and send messages.
|
| Sender.ConfirmSendContext<OMSG extends OutboundMessage> | |
| Sender.SendContext<OMSG extends OutboundMessage> | |
| SenderOptions |
Options for
Sender creation. |
| SendOptions |
Options for
Sender#send* methods. |
| Utils |
Set of utilities.
|
| Utils.SingleConnectionSupplier |
| Exception | Description |
|---|---|
| RabbitFluxException |
Common exception class for Reactor RabbitMQ library.
|
| RabbitFluxRetryTimeoutException |