com.huaweicloud.sdk.iot.device.transport.mqtt

类 MqttConnection

java.lang.Object

com.huaweicloud.sdk.iot.device.transport.mqtt.MqttConnection

所有已实现的接口:

Connection

public class MqttConnection
extends java.lang.Object
implements Connection

mqtt连接

构造器概要

构造器

构造器和说明
MqttConnection(ClientConf clientConf, RawMessageListener rawMessageListener)

方法概要

限定符和类型	方法和说明
void	close() 关闭连接
int	connect() 建立连接
boolean	isConnected() 是否连接中
void	publishMessage(RawMessage message, ActionListener listener) 发布消息
void	setConnectListener(ConnectListener connectListener) 设置连接监听器
void	setRawMessageListener(RawMessageListener rawMessageListener)
void	subscribeTopic(java.lang.String topic, ActionListener listener) 订阅指定主题

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

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

构造器详细资料

MqttConnection

public MqttConnection(ClientConf clientConf,
                      RawMessageListener rawMessageListener)

方法详细资料

connect

public int connect()

从接口复制的说明: Connection

建立连接

指定者:

connect 在接口中 Connection

返回:

连接建立结果，0表示成功，其他表示失败

publishMessage

public void publishMessage(RawMessage message,
                           ActionListener listener)

从接口复制的说明: Connection

发布消息

指定者:

publishMessage 在接口中 Connection

参数:

message - 消息

listener - 发布监听器

close

public void close()

从接口复制的说明: Connection

关闭连接

指定者:

close 在接口中 Connection

isConnected

public boolean isConnected()

从接口复制的说明: Connection

是否连接中

指定者:

isConnected 在接口中 Connection

返回:

true表示在连接中，false表示断连

setConnectListener

public void setConnectListener(ConnectListener connectListener)

从接口复制的说明: Connection

设置连接监听器

指定者:

setConnectListener 在接口中 Connection

参数:

connectListener - 连接监听器

setRawMessageListener

public void setRawMessageListener(RawMessageListener rawMessageListener)

subscribeTopic

public void subscribeTopic(java.lang.String topic,
                           ActionListener listener)

订阅指定主题

指定者:

subscribeTopic 在接口中 Connection

参数:

topic - 主题

listener - 监听订阅是否成功