Package io.micronaut.mqtt.hivemq.intercept

Class MqttSubscriberAdvice

java.lang.Object

io.micronaut.mqtt.intercept.AbstractMqttSubscriberAdvice<MqttMessage>

io.micronaut.mqtt.hivemq.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<MqttMessage>

The HiveMQ implementation of AbstractMqttSubscriberAdvice.

Since:

3.0.0

Author:

Sven Kobow

Constructor Summary

Constructors

Constructor	Description
MqttSubscriberAdvice(io.micronaut.context.BeanContext beanContext, MqttBinderRegistry binderRegistry, MqttSubscriberExceptionHandler exceptionHandler, MqttClientAdapter mqttClientAdapter)

Method Summary

Modifier and Type	Method	Description
void	subscribe(String[] topics, int[] qos, Consumer<MqttBindingContext<MqttMessage>> callback)
void	unsubscribe(Set<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 Details

MqttSubscriberAdvice

public MqttSubscriberAdvice(io.micronaut.context.BeanContext beanContext,
 MqttBinderRegistry binderRegistry,
 MqttSubscriberExceptionHandler exceptionHandler,
 MqttClientAdapter mqttClientAdapter)

Method Details

subscribe

public void subscribe(String[] topics,
 int[] qos,
 Consumer<MqttBindingContext<MqttMessage>> callback)

Specified by:

subscribe in class AbstractMqttSubscriberAdvice<MqttMessage>

unsubscribe

public void unsubscribe(Set<String> topics)

Specified by:

unsubscribe in class AbstractMqttSubscriberAdvice<MqttMessage>