io.micronaut.mqtt.v3.intercept

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<MqttSubscriber,io.micronaut.inject.ExecutableMethod<?,?>>, io.micronaut.context.processor.ExecutableMethodProcessor<MqttSubscriber>, java.lang.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

Constructor Summary

Constructors

Constructor and Description
MqttSubscriberAdvice(io.micronaut.context.BeanContext beanContext, MqttBinderRegistry binderRegistry, MqttSubscriberExceptionHandler exceptionHandler, org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient)

Method Summary

Modifier and Type	Method and Description
void	subscribe(java.lang.String[] topics, int[] qos, java.util.function.Consumer<MqttBindingContext<org.eclipse.paho.client.mqttv3.MqttMessage>> callback)
void	unsubscribe(java.util.Set<java.lang.String> topics)

Methods inherited from class io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice

close, process

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MqttSubscriberAdvice

public MqttSubscriberAdvice(io.micronaut.context.BeanContext beanContext,
                            MqttBinderRegistry binderRegistry,
                            MqttSubscriberExceptionHandler exceptionHandler,
                            org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient)

Method Detail

subscribe

public void subscribe(java.lang.String[] topics,
                      int[] qos,
                      java.util.function.Consumer<MqttBindingContext<org.eclipse.paho.client.mqttv3.MqttMessage>> callback)

Specified by:

subscribe in class AbstractMqttSubscriberAdvice<org.eclipse.paho.client.mqttv3.MqttMessage>

unsubscribe

public void unsubscribe(java.util.Set<java.lang.String> topics)

Specified by:

unsubscribe in class AbstractMqttSubscriberAdvice<org.eclipse.paho.client.mqttv3.MqttMessage>