Package br.com.anteros.mqtt.core.server.support

Class DefaultMqttServerProcessor

java.lang.Object

br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor

All Implemented Interfaces:

MqttServerProcessor

public class DefaultMqttServerProcessor
extends Object
implements MqttServerProcessor

mqtt broker 处理器

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
DefaultMqttServerProcessor(MqttServerCreator serverCreator, ScheduledThreadPoolExecutor executor)

Method Summary

Modifier and Type	Method	Description
void	processConnect(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttConnectMessage mqttMessage)	处理链接
void	processDisConnect(org.tio.core.ChannelContext context)	断开连接
void	processPingReq(org.tio.core.ChannelContext context)	ping 消息处理
void	processPubAck(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)	PubAck
void	processPubComp(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)	PubComp
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.MqttMessageIdVariableHeader variableHeader)	PubRec
void	processPubRel(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)	PubRel
void	processSubscribe(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttSubscribeMessage message)	监听
void	processUnSubscribe(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttUnsubscribeMessage message)	取消监听

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMqttServerProcessor

public DefaultMqttServerProcessor(MqttServerCreator serverCreator,
                                  ScheduledThreadPoolExecutor executor)

Method Detail

processConnect

public void processConnect(org.tio.core.ChannelContext context,
                           br.com.anteros.mqtt.codec.MqttConnectMessage mqttMessage)

Description copied from interface: MqttServerProcessor

处理链接

Specified by:

processConnect in interface MqttServerProcessor

Parameters:

context - ChannelContext

mqttMessage - MqttConnectMessage

processPublish

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

Description copied from interface: MqttServerProcessor

Publish

Specified by:

processPublish in interface MqttServerProcessor

Parameters:

context - ChannelContext

message - MqttPublishMessage

processPubAck

public void processPubAck(org.tio.core.ChannelContext context,
                          br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)

Description copied from interface: MqttServerProcessor

PubAck

Specified by:

processPubAck in interface MqttServerProcessor

Parameters:

context - ChannelContext

variableHeader - MqttMessageIdVariableHeader

processPubRec

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

Description copied from interface: MqttServerProcessor

PubRec

Specified by:

processPubRec in interface MqttServerProcessor

Parameters:

context - ChannelContext

variableHeader - MqttMessageIdVariableHeader

processPubRel

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

Description copied from interface: MqttServerProcessor

PubRel

Specified by:

processPubRel in interface MqttServerProcessor

Parameters:

context - ChannelContext

variableHeader - MqttMessageIdVariableHeader

processPubComp

public void processPubComp(org.tio.core.ChannelContext context,
                           br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)

Description copied from interface: MqttServerProcessor

PubComp

Specified by:

processPubComp in interface MqttServerProcessor

Parameters:

context - ChannelContext

variableHeader - MqttMessageIdVariableHeader

processSubscribe

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

Description copied from interface: MqttServerProcessor

监听

Specified by:

processSubscribe in interface MqttServerProcessor

Parameters:

context - ChannelContext

message - MqttSubscribeMessage

processUnSubscribe

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

Description copied from interface: MqttServerProcessor

取消监听

Specified by:

processUnSubscribe in interface MqttServerProcessor

Parameters:

context - ChannelContext

message - MqttUnsubscribeMessage

processPingReq

public void processPingReq(org.tio.core.ChannelContext context)

Description copied from interface: MqttServerProcessor

ping 消息处理

Specified by:

processPingReq in interface MqttServerProcessor

Parameters:

context - ChannelContext

processDisConnect

public void processDisConnect(org.tio.core.ChannelContext context)

Description copied from interface: MqttServerProcessor

断开连接

Specified by:

processDisConnect in interface MqttServerProcessor

Parameters:

context - ChannelContext