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

Interface MqttServerProcessor

  • All Known Implementing Classes:
    DefaultMqttServerProcessor
    public interface MqttServerProcessor
    mqtt broker 处理器
    Author:
    L.cm

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void processConnect​(org.tio.core.ChannelContext context, br.com.anteros.mqtt.codec.MqttConnectMessage message)
      处理链接
      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)
      取消监听

    • Method Detail

      • processConnect

        void processConnect​(org.tio.core.ChannelContext context,
                    br.com.anteros.mqtt.codec.MqttConnectMessage message)
        处理链接
        Parameters:
        context - ChannelContext
        message - MqttConnectMessage

      • processPublish

        void processPublish​(org.tio.core.ChannelContext context,
                    br.com.anteros.mqtt.codec.MqttPublishMessage message)
        Publish
        Parameters:
        context - ChannelContext
        message - MqttPublishMessage

      • processPubAck

        void processPubAck​(org.tio.core.ChannelContext context,
                   br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)
        PubAck
        Parameters:
        context - ChannelContext
        variableHeader - MqttMessageIdVariableHeader

      • processPubRec

        void processPubRec​(org.tio.core.ChannelContext context,
                   br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)
        PubRec
        Parameters:
        context - ChannelContext
        variableHeader - MqttMessageIdVariableHeader

      • processPubRel

        void processPubRel​(org.tio.core.ChannelContext context,
                   br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)
        PubRel
        Parameters:
        context - ChannelContext
        variableHeader - MqttMessageIdVariableHeader

      • processPubComp

        void processPubComp​(org.tio.core.ChannelContext context,
                    br.com.anteros.mqtt.codec.MqttMessageIdVariableHeader variableHeader)
        PubComp
        Parameters:
        context - ChannelContext
        variableHeader - MqttMessageIdVariableHeader

      • processSubscribe

        void processSubscribe​(org.tio.core.ChannelContext context,
                      br.com.anteros.mqtt.codec.MqttSubscribeMessage message)
        监听
        Parameters:
        context - ChannelContext
        message - MqttSubscribeMessage

      • processUnSubscribe

        void processUnSubscribe​(org.tio.core.ChannelContext context,
                        br.com.anteros.mqtt.codec.MqttUnsubscribeMessage message)
        取消监听
        Parameters:
        context - ChannelContext
        message - MqttUnsubscribeMessage

      • processPingReq

        void processPingReq​(org.tio.core.ChannelContext context)
        ping 消息处理
        Parameters:
        context - ChannelContext

      • processDisConnect

        void processDisConnect​(org.tio.core.ChannelContext context)
        断开连接
        Parameters:
        context - ChannelContext