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

Interface IMqttClientProcessor

  • All Known Implementing Classes:
    DefaultMqttClientProcessor
    public interface IMqttClientProcessor
    mqtt 客户端消息处理器
    Author:
    L.cm

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      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

    • Method Detail

      • processDecodeFailure

        void processDecodeFailure​(org.tio.core.ChannelContext context,
                          br.com.anteros.mqtt.codec.MqttMessage message,
                          Throwable ex)
        处理编解码失败
        Parameters:
        context - ChannelContext
        message - MqttMessage
        ex - Throwable

      • processConAck

        void processConAck​(org.tio.core.ChannelContext context,
                   br.com.anteros.mqtt.codec.MqttConnAckMessage message)
        处理服务端链接 ack
        Parameters:
        context - ChannelContext
        message - MqttConnAckMessage

      • processSubAck

        void processSubAck​(br.com.anteros.mqtt.codec.MqttSubAckMessage message)
        处理服务端订阅的 ack
        Parameters:
        message - MqttSubAckMessage

      • processPublish

        void processPublish​(org.tio.core.ChannelContext context,
                    br.com.anteros.mqtt.codec.MqttPublishMessage message)
        处理服务端 publish 的消息
        Parameters:
        context - ChannelContext
        message - MqttPublishMessage

      • processUnSubAck

        void processUnSubAck​(br.com.anteros.mqtt.codec.MqttUnsubAckMessage message)
        处理服务端解除订阅的 ack
        Parameters:
        message - MqttSubAckMessage

      • processPubAck

        void processPubAck​(br.com.anteros.mqtt.codec.MqttPubAckMessage message)
        处理服务端 publish 的 ack
        Parameters:
        message - MqttPubAckMessage

      • processPubRec

        void processPubRec​(org.tio.core.ChannelContext context,
                   br.com.anteros.mqtt.codec.MqttMessage message)
        处理服务端 publish rec
        Parameters:
        context - ChannelContext
        message - MqttPubAckMessage

      • processPubRel

        void processPubRel​(org.tio.core.ChannelContext context,
                   br.com.anteros.mqtt.codec.MqttMessage message)
        处理服务端 publish rel
        Parameters:
        context - ChannelContext
        message - MqttPubAckMessage

      • processPubComp

        void processPubComp​(br.com.anteros.mqtt.codec.MqttMessage message)
        处理服务端 publish comp
        Parameters:
        message - MqttPubAckMessage