org.noear.solon.cloud.extend.mqtt.service

类 MqttClientManagerImpl

java.lang.Object

org.noear.solon.cloud.extend.mqtt.service.MqttClientManagerImpl

所有已实现的接口:

org.eclipse.paho.client.mqttv3.MqttCallback, org.eclipse.paho.client.mqttv3.MqttCallbackExtended, MqttClientManager

public class MqttClientManagerImpl
extends java.lang.Object
implements MqttClientManager, org.eclipse.paho.client.mqttv3.MqttCallbackExtended

Mqtt 客户端管理器实现

从以下版本开始:

2.5

嵌套类概要

从接口继承的嵌套类/接口 org.noear.solon.cloud.extend.mqtt.service.MqttClientManager

MqttClientManager.ConnectCallback

构造器概要

构造器

构造器和说明
MqttClientManagerImpl(CloudEventObserverManger observerManger, CloudProps cloudProps)

方法概要

限定符和类型	方法和说明
void	addCallback(MqttClientManager.ConnectCallback connectCallback) 添加连接回调
void	connectComplete(boolean reconnect, java.lang.String serverURI)
void	connectionLost(java.lang.Throwable cause)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
boolean	getAsync() 获取异步状态
org.eclipse.paho.client.mqttv3.IMqttAsyncClient	getClient() 获取客户端
java.lang.String	getClientId() 获取客户端Id
void	messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
boolean	removeCallback(MqttClientManager.ConnectCallback connectCallback) 移除连接回调
void	setAsync(boolean async) 设置异步状态

从类继承的方法 java.lang.Object

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

构造器详细资料

MqttClientManagerImpl

public MqttClientManagerImpl(CloudEventObserverManger observerManger,
                             CloudProps cloudProps)

方法详细资料

connectionLost

public void connectionLost(java.lang.Throwable cause)

指定者:

connectionLost 在接口中 org.eclipse.paho.client.mqttv3.MqttCallback

messageArrived

public void messageArrived(java.lang.String topic,
                           org.eclipse.paho.client.mqttv3.MqttMessage message)
                    throws java.lang.Exception

指定者:

messageArrived 在接口中 org.eclipse.paho.client.mqttv3.MqttCallback

抛出:

java.lang.Exception

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)

指定者:

deliveryComplete 在接口中 org.eclipse.paho.client.mqttv3.MqttCallback

connectComplete

public void connectComplete(boolean reconnect,
                            java.lang.String serverURI)

指定者:

connectComplete 在接口中 org.eclipse.paho.client.mqttv3.MqttCallbackExtended

getClient

public org.eclipse.paho.client.mqttv3.IMqttAsyncClient getClient()

获取客户端

指定者:

getClient 在接口中 MqttClientManager

getClientId

public java.lang.String getClientId()

从接口复制的说明: MqttClientManager

获取客户端Id

指定者:

getClientId 在接口中 MqttClientManager

setAsync

public void setAsync(boolean async)

从接口复制的说明: MqttClientManager

设置异步状态

指定者:

setAsync 在接口中 MqttClientManager

getAsync

public boolean getAsync()

从接口复制的说明: MqttClientManager

获取异步状态

指定者:

getAsync 在接口中 MqttClientManager

addCallback

public void addCallback(MqttClientManager.ConnectCallback connectCallback)

从接口复制的说明: MqttClientManager

添加连接回调

指定者:

addCallback 在接口中 MqttClientManager

removeCallback

public boolean removeCallback(MqttClientManager.ConnectCallback connectCallback)

从接口复制的说明: MqttClientManager

移除连接回调

指定者:

removeCallback 在接口中 MqttClientManager