org.noear.solon.cloud.extend.mqtt5.service

类 MqttClientManagerImpl

java.lang.Object

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

所有已实现的接口:

org.eclipse.paho.mqttv5.client.MqttCallback, MqttClientManager

public class MqttClientManagerImpl
extends java.lang.Object
implements MqttClientManager, org.eclipse.paho.mqttv5.client.MqttCallback

Mqtt 客户端管理器实现

从以下版本开始:

2.5

嵌套类概要

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

MqttClientManager.ConnectCallback

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
void	addCallback(MqttClientManager.ConnectCallback connectCallback) 添加连接回调
void	authPacketArrived(int reasonCode, org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)
void	connectComplete(boolean reconnect, java.lang.String serverURI)
void	deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)
void	disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)
boolean	getAsync() 获取异步状态
org.eclipse.paho.mqttv5.client.IMqttAsyncClient	getClient() 获取客户端
java.lang.String	getClientId() 获取客户端Id
void	messageArrived(java.lang.String topic, org.eclipse.paho.mqttv5.common.MqttMessage message)
void	mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)
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)

方法详细资料

disconnected

public void disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)

指定者:

disconnected 在接口中 org.eclipse.paho.mqttv5.client.MqttCallback

mqttErrorOccurred

public void mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)

指定者:

mqttErrorOccurred 在接口中 org.eclipse.paho.mqttv5.client.MqttCallback

messageArrived

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

指定者:

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

抛出:

java.lang.Exception

deliveryComplete

public void deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)

指定者:

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

connectComplete

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

指定者:

connectComplete 在接口中 org.eclipse.paho.mqttv5.client.MqttCallback

authPacketArrived

public void authPacketArrived(int reasonCode,
                              org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)

指定者:

authPacketArrived 在接口中 org.eclipse.paho.mqttv5.client.MqttCallback

getClient

public org.eclipse.paho.mqttv5.client.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