com.feingto.iot.client.service

接口 IMqttMessage

所有已知实现类:

MqttClient, MqttMessageService

public interface IMqttMessage

消息接口

作者:

longfei

方法概要

限定符和类型	方法和说明
void	connack(io.netty.handler.codec.mqtt.MqttConnAckMessage msg) 连接响应
void	connect(io.netty.channel.Channel channel, MqttConnectOptions options) 连接
void	disconnect(io.netty.channel.Channel channel) 断开连接消息
void	exceptionCaught(Throwable cause) 异常处理
void	pingreq(io.netty.channel.Channel channel) PING请求
void	puback(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttMessage msg) QoS level = 1的消息响应
void	pubcomp(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttMessage msg) Qos level = 2的协议流的第三个消息响应
void	publish(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttMessage msg) 推送消息
void	pubrec(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttMessage msg) Qos level = 2的协议流的第二个消息，确认已经收到
void	pubrel(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttMessage msg) Qos level = 2的协议流的第三个消息
void	suback(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttSubAckMessage msg) 订阅响应
void	unsubBack(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttMessage msg) 取消订阅响应

方法详细资料

connect

void connect(io.netty.channel.Channel channel,
             MqttConnectOptions options)

连接

connack

void connack(io.netty.handler.codec.mqtt.MqttConnAckMessage msg)

连接响应

publish

void publish(io.netty.channel.Channel channel,
             io.netty.handler.codec.mqtt.MqttMessage msg)

推送消息

puback

void puback(io.netty.channel.Channel channel,
            io.netty.handler.codec.mqtt.MqttMessage msg)

QoS level = 1的消息响应

pubrec

void pubrec(io.netty.channel.Channel channel,
            io.netty.handler.codec.mqtt.MqttMessage msg)

Qos level = 2的协议流的第二个消息，确认已经收到

pubrel

void pubrel(io.netty.channel.Channel channel,
            io.netty.handler.codec.mqtt.MqttMessage msg)

Qos level = 2的协议流的第三个消息

pubcomp

void pubcomp(io.netty.channel.Channel channel,
             io.netty.handler.codec.mqtt.MqttMessage msg)

Qos level = 2的协议流的第三个消息响应

suback

void suback(io.netty.channel.Channel channel,
            io.netty.handler.codec.mqtt.MqttSubAckMessage msg)

订阅响应

unsubBack

void unsubBack(io.netty.channel.Channel channel,
               io.netty.handler.codec.mqtt.MqttMessage msg)

取消订阅响应

pingreq

void pingreq(io.netty.channel.Channel channel)

PING请求

disconnect

void disconnect(io.netty.channel.Channel channel)

断开连接消息

exceptionCaught

void exceptionCaught(Throwable cause)

异常处理