Class MqttSubscriberAdvice

java.lang.Object
io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice<org.eclipse.paho.mqttv5.common.MqttMessage>
io.micronaut.mqtt.v5.intercept.MqttSubscriberAdvice
All Implemented Interfaces:
io.micronaut.context.processor.AnnotationProcessor<Topic,io.micronaut.inject.ExecutableMethod<?,?>>, io.micronaut.context.processor.ExecutableMethodProcessor<Topic>, AutoCloseable

@Singleton public class MqttSubscriberAdvice extends AbstractMqttSubscriberAdvice<org.eclipse.paho.mqttv5.common.MqttMessage>
The MQTT v5 implementation of AbstractMqttSubscriberAdvice.
Since:
1.0.0
Author:
James Kleeh