程序包 cn.hserver.plugin.mqtt.interfaces

类 MqttAdapter

java.lang.Object
cn.hserver.plugin.mqtt.interfaces.MqttAdapter
public abstract class MqttAdapter extends Object
Aop
作者:
hxm

  • 构造器概要

    构造器
    构造器
    说明
    MqttAdapter()
     

  • 方法概要

    修饰符和类型
    方法
    说明
    void
    channelActive(io.netty.channel.ChannelHandlerContext ctx)
     
    void
    channelInactive(io.netty.channel.ChannelHandlerContext ctx)
     
    void
    connect(io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)
     
    void
    disconnect(io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)
     
    void
    exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
     
    abstract void
    message(io.netty.handler.codec.mqtt.MqttMessageType type, io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)
    消息处理
    void
    pingReq(io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)
     
    void
    userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)
     

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

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

  • 构造器详细资料

    • MqttAdapter

      public MqttAdapter()

  • 方法详细资料

    • channelActive

      public void channelActive(io.netty.channel.ChannelHandlerContext ctx) throws Exception
      抛出:
      Exception

    • channelInactive

      public void channelInactive(io.netty.channel.ChannelHandlerContext ctx) throws Exception
      抛出:
      Exception

    • connect

      public void connect(io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)

    • pingReq

      public void pingReq(io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)

    • disconnect

      public void disconnect(io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)

    • userEventTriggered

      public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)

    • exceptionCaught

      public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)

    • message

      public abstract void message(io.netty.handler.codec.mqtt.MqttMessageType type, io.netty.handler.codec.mqtt.MqttMessage mqttMessage, io.netty.channel.ChannelHandlerContext ctx)
      消息处理