@DefaultImplementation(value=DefaultMqttSubscriberExceptionHandler.class) public interface MqttSubscriberExceptionHandler extends io.micronaut.core.exceptions.ExceptionHandler<MqttSubscriberException>
MqttSubscriber
beans to handle
exceptions thrown specific to that class.
Replace this with your own Primary
bean to handle
exceptions not handled by any other listeners.