com.feingto.iot.client.service

类 MqttMessageService

java.lang.Object

com.feingto.iot.client.service.MqttMessageService

所有已实现的接口:

IMqttMessage

直接已知子类:

MqttClient

public class MqttMessageService
extends Object
implements IMqttMessage

MQTT 消息服务

作者:

longfei

构造器概要

构造器

构造器和说明
MqttMessageService()

方法概要

限定符和类型	方法和说明
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) 取消订阅响应

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

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

构造器详细资料

MqttMessageService

public MqttMessageService()

方法详细资料

connect

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

从接口复制的说明: IMqttMessage

连接

指定者:

connect 在接口中 IMqttMessage

connack

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

从接口复制的说明: IMqttMessage

连接响应

指定者:

connack 在接口中 IMqttMessage

publish

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

从接口复制的说明: IMqttMessage

推送消息

指定者:

publish 在接口中 IMqttMessage

puback

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

从接口复制的说明: IMqttMessage

QoS level = 1的消息响应

指定者:

puback 在接口中 IMqttMessage

pubrec

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

从接口复制的说明: IMqttMessage

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

指定者:

pubrec 在接口中 IMqttMessage

pubrel

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

从接口复制的说明: IMqttMessage

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

指定者:

pubrel 在接口中 IMqttMessage

pubcomp

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

从接口复制的说明: IMqttMessage

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

指定者:

pubcomp 在接口中 IMqttMessage

suback

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

从接口复制的说明: IMqttMessage

订阅响应

指定者:

suback 在接口中 IMqttMessage

unsubBack

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

从接口复制的说明: IMqttMessage

取消订阅响应

指定者:

unsubBack 在接口中 IMqttMessage

pingreq

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

从接口复制的说明: IMqttMessage

PING请求

指定者:

pingreq 在接口中 IMqttMessage

disconnect

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

从接口复制的说明: IMqttMessage

断开连接消息

指定者:

disconnect 在接口中 IMqttMessage

exceptionCaught

public void exceptionCaught(Throwable cause)

从接口复制的说明: IMqttMessage

异常处理

指定者:

exceptionCaught 在接口中 IMqttMessage