io.smallrye.reactive.messaging.mqtt

Interface MqttFailureHandler

All Known Implementing Classes:

MqttFailStop, MqttIgnoreFailure

public interface MqttFailureHandler

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	MqttFailureHandler.Strategy

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	handle(Throwable reason)

Method Detail

handle

CompletionStage<Void> handle(Throwable reason)