Class RabbitMQReject
- java.lang.Object
-
- io.smallrye.reactive.messaging.rabbitmq.fault.RabbitMQReject
-
- All Implemented Interfaces:
RabbitMQFailureHandler
public class RabbitMQReject extends Object implements RabbitMQFailureHandler
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.rabbitmq.fault.RabbitMQFailureHandler
RabbitMQFailureHandler.Strategy
-
-
Constructor Summary
Constructors Constructor Description RabbitMQReject(String channel)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <V> CompletionStage<Void>
handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context, Throwable reason)
Handle message failure.
-
-
-
Constructor Detail
-
RabbitMQReject
public RabbitMQReject(String channel)
Constructor.- Parameters:
channel
- the channel
-
-
Method Detail
-
handle
public <V> CompletionStage<Void> handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context, Throwable reason)
Description copied from interface:RabbitMQFailureHandler
Handle message failure.- Specified by:
handle
in interfaceRabbitMQFailureHandler
- Type Parameters:
V
- message body type- Parameters:
msg
- the failed messagecontext
- theContext
in which the handling should be donereason
- the reason for the failure- Returns:
- a
CompletionStage
-
-