Package io.micronaut.mqtt.hivemq.client

Interface MqttClientAdapter

All Known Implementing Classes:

Mqtt3ClientAdapter, Mqtt5ClientAdapter

public interface MqttClientAdapter

Common interface for HiveMQ MQTT clients.

Since:

3.0.0

Author:

Sven Kobow

Method Summary

Modifier and Type	Method	Description
Object	getClientIdentifier()
default Map<String,Integer>	getTopicMap(String[] topics, int[] qos)
boolean	isConnected()
void	subscribe(String[] topics, int[] qos, Consumer<MqttBindingContext<MqttMessage>> callback)
void	unsubscribe(Set<String> topics)

Method Details

subscribe

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

getTopicMap

default Map<String,Integer> getTopicMap(String[] topics,
 int[] qos)

unsubscribe

void unsubscribe(Set<String> topics)

isConnected

boolean isConnected()

getClientIdentifier

Object getClientIdentifier()