io.smallrye.reactive.messaging.rabbitmq.fault

Class RabbitMQFailStop

java.lang.Object

io.smallrye.reactive.messaging.rabbitmq.fault.RabbitMQFailStop

All Implemented Interfaces:

RabbitMQFailureHandler

public class RabbitMQFailStop
extends Object
implements RabbitMQFailureHandler

A RabbitMQFailureHandler that rejects the message and reports a failure.

Nested Class Summary

Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.rabbitmq.fault.RabbitMQFailureHandler

RabbitMQFailureHandler.Strategy

Constructor Summary

Constructors

Constructor and Description
RabbitMQFailStop(RabbitMQConnector connector, String channel) Constructor.

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RabbitMQFailStop

public RabbitMQFailStop(RabbitMQConnector connector,
                        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 interface RabbitMQFailureHandler

Type Parameters:

V - message body type

Parameters:

msg - the failed message

context - the Context in which the handling should be done

reason - the reason for the failure

Returns:

a CompletionStage