Class MqttSubscriberAdvice

java.lang.Object
io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice<org.eclipse.paho.client.mqttv3.MqttMessage>
io.micronaut.mqtt.v3.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.client.mqttv3.MqttMessage>
The MQTT v3 implementation of AbstractMqttSubscriberAdvice.
Since:
1.0.0
Author:
James Kleeh