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
The HiveMQ implementation of
AbstractMqttSubscriberAdvice
.- Since:
- 3.0.0
- Author:
- Sven Kobow
-
Constructor Summary
ConstructorDescriptionMqttSubscriberAdvice
(io.micronaut.context.BeanContext beanContext, MqttBinderRegistry binderRegistry, MqttSubscriberExceptionHandler exceptionHandler, MqttClientAdapter mqttClientAdapter) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
-
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 classAbstractMqttSubscriberAdvice<MqttMessage>
-
unsubscribe
- Specified by:
unsubscribe
in classAbstractMqttSubscriberAdvice<MqttMessage>
-