public class MqttClientManagerImpl extends java.lang.Object implements MqttClientManager, org.eclipse.paho.mqttv5.client.MqttCallback
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)
设置异步状态
|
public MqttClientManagerImpl(CloudEventObserverManger observerManger, CloudProps cloudProps)
public void disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)
disconnected
在接口中 org.eclipse.paho.mqttv5.client.MqttCallback
public void mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)
mqttErrorOccurred
在接口中 org.eclipse.paho.mqttv5.client.MqttCallback
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
public void deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)
deliveryComplete
在接口中 org.eclipse.paho.mqttv5.client.MqttCallback
public void connectComplete(boolean reconnect, java.lang.String serverURI)
connectComplete
在接口中 org.eclipse.paho.mqttv5.client.MqttCallback
public void authPacketArrived(int reasonCode, org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)
authPacketArrived
在接口中 org.eclipse.paho.mqttv5.client.MqttCallback
public org.eclipse.paho.mqttv5.client.IMqttAsyncClient getClient()
getClient
在接口中 MqttClientManager
public java.lang.String getClientId()
MqttClientManager
getClientId
在接口中 MqttClientManager
public void setAsync(boolean async)
MqttClientManager
setAsync
在接口中 MqttClientManager
public boolean getAsync()
MqttClientManager
getAsync
在接口中 MqttClientManager
public void addCallback(MqttClientManager.ConnectCallback connectCallback)
MqttClientManager
addCallback
在接口中 MqttClientManager
public boolean removeCallback(MqttClientManager.ConnectCallback connectCallback)
MqttClientManager
removeCallback
在接口中 MqttClientManager