Package br.com.anteros.mqtt.core.client

Class DefaultMqttClientProcessor

java.lang.Object

br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor

All Implemented Interfaces:

IMqttClientProcessor

public class DefaultMqttClientProcessor
extends Object
implements IMqttClientProcessor

默认的 mqtt 消息处理器

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
DefaultMqttClientProcessor(MqttClientCreator mqttClientCreator)

Method Summary

Modifier and Type	Method	Description
void	processConAck(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttConnAckMessage message)	处理服务端链接 ack
void	processDecodeFailure(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttMessage message, Throwable ex)	处理编解码失败
void	processPubAck(br.com.anteros.mqtt.codec.MqttPubAckMessage message)	处理服务端 publish 的 ack
void	processPubComp(br.com.anteros.mqtt.codec.MqttMessage message)	处理服务端 publish comp
void	processPublish(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttPublishMessage message)	处理服务端 publish 的消息
void	processPubRec(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttMessage message)	处理服务端 publish rec
void	processPubRel(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttMessage message)	处理服务端 publish rel
void	processSubAck(br.com.anteros.mqtt.codec.MqttSubAckMessage message)	处理服务端订阅的 ack
void	processUnSubAck(br.com.anteros.mqtt.codec.MqttUnsubAckMessage message)	处理服务端解除订阅的 ack

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMqttClientProcessor

public DefaultMqttClientProcessor(MqttClientCreator mqttClientCreator)

Method Detail

processDecodeFailure

public void processDecodeFailure(org.tio.core.ChannelContext context,
                                 br.com.anteros.mqtt.codec.MqttMessage message,
                                 Throwable ex)

Description copied from interface: IMqttClientProcessor

处理编解码失败

Specified by:

processDecodeFailure in interface IMqttClientProcessor

Parameters:

context - ChannelContext

message - MqttMessage

ex - Throwable

processConAck

public void processConAck(org.tio.core.ChannelContext context,
                          br.com.anteros.mqtt.codec.MqttConnAckMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端链接 ack

Specified by:

processConAck in interface IMqttClientProcessor

Parameters:

context - ChannelContext

message - MqttConnAckMessage

processSubAck

public void processSubAck(br.com.anteros.mqtt.codec.MqttSubAckMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端订阅的 ack

Specified by:

processSubAck in interface IMqttClientProcessor

Parameters:

message - MqttSubAckMessage

processPublish

public void processPublish(org.tio.core.ChannelContext context,
                           br.com.anteros.mqtt.codec.MqttPublishMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端 publish 的消息

Specified by:

processPublish in interface IMqttClientProcessor

Parameters:

context - ChannelContext

message - MqttPublishMessage

processUnSubAck

public void processUnSubAck(br.com.anteros.mqtt.codec.MqttUnsubAckMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端解除订阅的 ack

Specified by:

processUnSubAck in interface IMqttClientProcessor

Parameters:

message - MqttSubAckMessage

processPubAck

public void processPubAck(br.com.anteros.mqtt.codec.MqttPubAckMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端 publish 的 ack

Specified by:

processPubAck in interface IMqttClientProcessor

Parameters:

message - MqttPubAckMessage

processPubRec

public void processPubRec(org.tio.core.ChannelContext context,
                          br.com.anteros.mqtt.codec.MqttMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端 publish rec

Specified by:

processPubRec in interface IMqttClientProcessor

Parameters:

context - ChannelContext

message - MqttPubAckMessage

processPubRel

public void processPubRel(org.tio.core.ChannelContext context,
                          br.com.anteros.mqtt.codec.MqttMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端 publish rel

Specified by:

processPubRel in interface IMqttClientProcessor

Parameters:

context - ChannelContext

message - MqttPubAckMessage

processPubComp

public void processPubComp(br.com.anteros.mqtt.codec.MqttMessage message)

Description copied from interface: IMqttClientProcessor

处理服务端 publish comp

Specified by:

processPubComp in interface IMqttClientProcessor

Parameters:

message - MqttPubAckMessage