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 |