Package io.smallrye.reactive.messaging.amqp.fault

Class AmqpFailStop

java.lang.Object

io.smallrye.reactive.messaging.amqp.fault.AmqpFailStop

All Implemented Interfaces:

AmqpFailureHandler

public class AmqpFailStop
extends Object
implements AmqpFailureHandler

Nested Class Summary

Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.amqp.fault.AmqpFailureHandler

AmqpFailureHandler.Strategy

Constructor Summary

Constructors

Constructor	Description
AmqpFailStop(AmqpConnector connector, String channel)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpFailStop

public AmqpFailStop(AmqpConnector connector,
                    String channel)

Method Detail

handle

public <V> CompletionStage<Void> handle(AmqpMessage<V> msg,
                                        io.vertx.mutiny.core.Context context,
                                        Throwable reason)

Specified by:

handle in interface AmqpFailureHandler