Package io.smallrye.reactive.messaging.rabbitmq.fault

Interface RabbitMQFailureHandler

All Known Implementing Classes:

RabbitMQAccept, RabbitMQFailStop, RabbitMQReject

public interface RabbitMQFailureHandler

Implemented to provide message failure strategies.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	RabbitMQFailureHandler.Strategy

Method Summary

Modifier and Type	Method	Description
<V> CompletionStage<Void>	handle(IncomingRabbitMQMessage<V> message, io.vertx.mutiny.core.Context context, Throwable reason)	Handle message failure.

Method Detail

handle

<V> CompletionStage<Void> handle(IncomingRabbitMQMessage<V> message,
                                 io.vertx.mutiny.core.Context context,
                                 Throwable reason)

Handle message failure.

Type Parameters:

V - message body type

Parameters:

message - the failed message

context - the Context in which the handling should be done

reason - the reason for the failure

Returns:

a CompletionStage