Uses of Interface
org.springframework.integration.mqtt.core.ClientManager
Package
Description
Provides core classes of the MqttAdapter module.
Provides inbound Spring Integration MqttAdapter components.
Provides Spring Integration components for doing outbound operations.
-
Uses of ClientManager in org.springframework.integration.mqtt.core
Modifier and TypeClassDescriptionclass
Abstract class for MQTT client managers which can be a base for any common v3/v5 client manager implementation.class
A client manager implementation for MQTT v3 protocol.class
A client manager implementation for MQTT v5 protocol. -
Uses of ClientManager in org.springframework.integration.mqtt.inbound
Modifier and TypeMethodDescriptionprotected ClientManager<T,
C> AbstractMqttMessageDrivenChannelAdapter.getClientManager()
ModifierConstructorDescriptionAbstractMqttMessageDrivenChannelAdapter
(ClientManager<T, C> clientManager, String... topic) MqttPahoMessageDrivenChannelAdapter
(ClientManager<org.eclipse.paho.client.mqttv3.IMqttAsyncClient, org.eclipse.paho.client.mqttv3.MqttConnectOptions> clientManager, String... topic) Use this constructor when you need to use a singleClientManager
(for instance, to reuse an MQTT connection).Mqttv5PahoMessageDrivenChannelAdapter
(ClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> clientManager, String... topic) Use this constructor when you need to use a singleClientManager
(for instance, to reuse an MQTT connection).Mqttv5PahoMessageDrivenChannelAdapter
(ClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> clientManager, org.eclipse.paho.mqttv5.common.MqttSubscription... mqttSubscriptions) Create an instance based on the client manager and subscriptions. -
Uses of ClientManager in org.springframework.integration.mqtt.outbound
Modifier and TypeMethodDescriptionprotected ClientManager<T,
C> AbstractMqttMessageHandler.getClientManager()
ModifierConstructorDescriptionAbstractMqttMessageHandler
(ClientManager<T, C> clientManager) MqttPahoMessageHandler
(ClientManager<org.eclipse.paho.client.mqttv3.IMqttAsyncClient, org.eclipse.paho.client.mqttv3.MqttConnectOptions> clientManager) Use this constructor when you need to use a singleClientManager
(for instance, to reuse an MQTT connection).Mqttv5PahoMessageHandler
(ClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> clientManager) Use this constructor when you need to use a singleClientManager
(for instance, to reuse an MQTT connection).