Class MqttIgnoreFailure
- java.lang.Object
-
- io.smallrye.reactive.messaging.mqtt.MqttIgnoreFailure
-
- All Implemented Interfaces:
MqttFailureHandler
public class MqttIgnoreFailure extends Object implements MqttFailureHandler
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.mqtt.MqttFailureHandler
MqttFailureHandler.Strategy
-
-
Constructor Summary
Constructors Constructor Description MqttIgnoreFailure(String channel)
-
-
-
Constructor Detail
-
MqttIgnoreFailure
public MqttIgnoreFailure(String channel)
-
-
Method Detail
-
handle
public CompletionStage<Void> handle(Throwable reason)
- Specified by:
handle
in interfaceMqttFailureHandler
-
-