io.vertx/vertx-mqtt/4.0.0 : io/vertx/mqtt/impl/MqttServerConnection.class

MqttServerConnection
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-mqtt: Vert.x MQTT reactive client and server (Eclipse)
The Apache License, Version 2.0
Paolo Patierno (Red Hat)
public class io.vertx.mqtt.impl.MqttServerConnection
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.mqtt.impl.MqttServerConnection
  super_class: java.lang.Object
{
  private static final io.vertx.core.impl.logging.Logger log;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private io.vertx.core.Handler<io.vertx.mqtt.MqttEndpoint> endpointHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;

  private io.vertx.core.Handler<java.lang.Throwable> exceptionHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/lang/Throwable;>;

  private final io.vertx.core.net.impl.NetSocketInternal so;
    descriptor: Lio/vertx/core/net/impl/NetSocketInternal;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private io.vertx.mqtt.impl.MqttEndpointImpl endpoint;
    descriptor: Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0002) ACC_PRIVATE

  private final io.netty.channel.ChannelHandlerContext chctx;
    descriptor: Lio/netty/channel/ChannelHandlerContext;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.mqtt.MqttServerOptions options;
    descriptor: Lio/vertx/mqtt/MqttServerOptions;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private static volatile int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 51
            ldc Lio/vertx/mqtt/impl/MqttServerConnection;
            invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
            putstatic io.vertx.mqtt.impl.MqttServerConnection.log:Lio/vertx/core/impl/logging/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(io.vertx.core.net.impl.NetSocketInternal, io.vertx.core.Handler<io.vertx.mqtt.MqttEndpoint>, io.vertx.core.Handler<java.lang.Throwable>, io.vertx.mqtt.MqttServerOptions);
    descriptor: (Lio/vertx/core/net/impl/NetSocketInternal;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/mqtt/MqttServerOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=5, args_size=5
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // io.vertx.core.net.impl.NetSocketInternal so
        start local 2 // io.vertx.core.Handler endpointHandler
        start local 3 // io.vertx.core.Handler exceptionHandler
        start local 4 // io.vertx.mqtt.MqttServerOptions options
         0: .line 66
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 70
            aload 0 /* this */
            aload 1 /* so */
            putfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
         2: .line 71
            aload 0 /* this */
            aload 2 /* endpointHandler */
            putfield io.vertx.mqtt.impl.MqttServerConnection.endpointHandler:Lio/vertx/core/Handler;
         3: .line 72
            aload 0 /* this */
            aload 3 /* exceptionHandler */
            putfield io.vertx.mqtt.impl.MqttServerConnection.exceptionHandler:Lio/vertx/core/Handler;
         4: .line 73
            aload 0 /* this */
            aload 1 /* so */
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
            putfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
         5: .line 74
            aload 0 /* this */
            aload 4 /* options */
            putfield io.vertx.mqtt.impl.MqttServerConnection.options:Lio/vertx/mqtt/MqttServerOptions;
         6: .line 75
            return
        end local 4 // io.vertx.mqtt.MqttServerOptions options
        end local 3 // io.vertx.core.Handler exceptionHandler
        end local 2 // io.vertx.core.Handler endpointHandler
        end local 1 // io.vertx.core.net.impl.NetSocketInternal so
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    7     1                so  Lio/vertx/core/net/impl/NetSocketInternal;
            0    7     2   endpointHandler  Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;
            0    7     3  exceptionHandler  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
            0    7     4           options  Lio/vertx/mqtt/MqttServerOptions;
    Signature: (Lio/vertx/core/net/impl/NetSocketInternal;Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;Lio/vertx/core/Handler<Ljava/lang/Throwable;>;Lio/vertx/mqtt/MqttServerOptions;)V
    MethodParameters:
                  Name  Flags
      so                
      endpointHandler   
      exceptionHandler  
      options           

  void handleMessage(java.lang.Object);
    descriptor: (Ljava/lang/Object;)V
    flags: (0x0000) 
    Code:
      stack=11, locals=15, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // java.lang.Object msg
         0: .line 86
            aload 1 /* msg */
            instanceof io.netty.handler.codec.mqtt.MqttMessage
            ifeq 58
         1: .line 88
            aload 1 /* msg */
            checkcast io.netty.handler.codec.mqtt.MqttMessage
            astore 2 /* mqttMessage */
        start local 2 // io.netty.handler.codec.mqtt.MqttMessage mqttMessage
         2: .line 90
            aload 2 /* mqttMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessage.decoderResult:()Lio/netty/handler/codec/DecoderResult;
            astore 3 /* result */
        start local 3 // io.netty.handler.codec.DecoderResult result
         3: .line 91
            aload 3 /* result */
            invokevirtual io.netty.handler.codec.DecoderResult.isFailure:()Z
            ifeq 11
         4: .line 92
            aload 3 /* result */
            invokevirtual io.netty.handler.codec.DecoderResult.cause:()Ljava/lang/Throwable;
            astore 4 /* cause */
        start local 4 // java.lang.Throwable cause
         5: .line 93
            aload 4 /* cause */
            instanceof io.netty.handler.codec.mqtt.MqttUnacceptableProtocolVersionException
            ifeq 9
         6: .line 94
            aload 0 /* this */
            new io.vertx.mqtt.impl.MqttEndpointImpl
            dup
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            aconst_null
            aconst_null
            aconst_null
            iconst_0
            iconst_0
            aconst_null
            iconst_0
            invokespecial io.vertx.mqtt.impl.MqttEndpointImpl.<init>:(Lio/vertx/core/net/impl/NetSocketInternal;Ljava/lang/String;Lio/vertx/mqtt/MqttAuth;Lio/vertx/mqtt/MqttWill;ZILjava/lang/String;I)V
            putfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
         7: .line 95
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_REFUSED_UNACCEPTABLE_PROTOCOL_VERSION:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.reject:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         8: .line 96
            goto 10
         9: .line 97
      StackMap locals: io.netty.handler.codec.mqtt.MqttMessage io.netty.handler.codec.DecoderResult java.lang.Throwable
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            aload 3 /* result */
            invokevirtual io.netty.handler.codec.DecoderResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
            pop
        10: .line 99
      StackMap locals:
      StackMap stack:
            return
        end local 4 // java.lang.Throwable cause
        11: .line 101
      StackMap locals:
      StackMap stack:
            aload 3 /* result */
            invokevirtual io.netty.handler.codec.DecoderResult.isFinished:()Z
            ifne 14
        12: .line 102
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            new java.lang.Exception
            dup
            ldc "Unfinished message"
            invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
            invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
            pop
        13: .line 103
            return
        14: .line 106
      StackMap locals:
      StackMap stack:
            invokestatic io.vertx.mqtt.impl.MqttServerConnection.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:()[I
            aload 2 /* mqttMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.messageType:()Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            iaload
            tableswitch { // 1 - 14
                    1: 15
                    2: 56
                    3: 29
                    4: 40
                    5: 43
                    6: 46
                    7: 49
                    8: 17
                    9: 56
                   10: 23
                   11: 56
                   12: 52
                   13: 56
                   14: 54
              default: 56
          }
        15: .line 109
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* msg */
            checkcast io.netty.handler.codec.mqtt.MqttConnectMessage
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleConnect:(Lio/netty/handler/codec/mqtt/MqttConnectMessage;)V
        16: .line 110
            goto 59
        17: .line 114
      StackMap locals:
      StackMap stack:
            aload 2 /* mqttMessage */
            checkcast io.netty.handler.codec.mqtt.MqttSubscribeMessage
            astore 4 /* subscribe */
        start local 4 // io.netty.handler.codec.mqtt.MqttSubscribeMessage subscribe
        18: .line 117
            aload 4 /* subscribe */
            invokevirtual io.netty.handler.codec.mqtt.MqttSubscribeMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
        19: .line 118
            aload 4 /* subscribe */
            invokevirtual io.netty.handler.codec.mqtt.MqttSubscribeMessage.payload:()Lio/netty/handler/codec/mqtt/MqttSubscribePayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttSubscribePayload.topicSubscriptions:()Ljava/util/List;
        20: .line 116
            invokestatic io.vertx.mqtt.messages.MqttSubscribeMessage.create:(ILjava/util/List;)Lio/vertx/mqtt/messages/MqttSubscribeMessage;
            astore 5 /* mqttSubscribeMessage */
        start local 5 // io.vertx.mqtt.messages.MqttSubscribeMessage mqttSubscribeMessage
        21: .line 119
            aload 0 /* this */
            aload 5 /* mqttSubscribeMessage */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleSubscribe:(Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V
        22: .line 120
            goto 59
        end local 5 // io.vertx.mqtt.messages.MqttSubscribeMessage mqttSubscribeMessage
        end local 4 // io.netty.handler.codec.mqtt.MqttSubscribeMessage subscribe
        23: .line 124
      StackMap locals:
      StackMap stack:
            aload 2 /* mqttMessage */
            checkcast io.netty.handler.codec.mqtt.MqttUnsubscribeMessage
            astore 6 /* unsubscribe */
        start local 6 // io.netty.handler.codec.mqtt.MqttUnsubscribeMessage unsubscribe
        24: .line 127
            aload 6 /* unsubscribe */
            invokevirtual io.netty.handler.codec.mqtt.MqttUnsubscribeMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
        25: .line 128
            aload 6 /* unsubscribe */
            invokevirtual io.netty.handler.codec.mqtt.MqttUnsubscribeMessage.payload:()Lio/netty/handler/codec/mqtt/MqttUnsubscribePayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttUnsubscribePayload.topics:()Ljava/util/List;
        26: .line 126
            invokestatic io.vertx.mqtt.messages.MqttUnsubscribeMessage.create:(ILjava/util/List;)Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;
            astore 7 /* mqttUnsubscribeMessage */
        start local 7 // io.vertx.mqtt.messages.MqttUnsubscribeMessage mqttUnsubscribeMessage
        27: .line 129
            aload 0 /* this */
            aload 7 /* mqttUnsubscribeMessage */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleUnsubscribe:(Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V
        28: .line 130
            goto 59
        end local 7 // io.vertx.mqtt.messages.MqttUnsubscribeMessage mqttUnsubscribeMessage
        end local 6 // io.netty.handler.codec.mqtt.MqttUnsubscribeMessage unsubscribe
        29: .line 134
      StackMap locals:
      StackMap stack:
            aload 2 /* mqttMessage */
            checkcast io.netty.handler.codec.mqtt.MqttPublishMessage
            astore 8 /* publish */
        start local 8 // io.netty.handler.codec.mqtt.MqttPublishMessage publish
        30: .line 135
            aload 8 /* publish */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.payload:()Lio/netty/buffer/ByteBuf;
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
            invokestatic io.vertx.core.net.impl.VertxHandler.safeBuffer:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
            astore 9 /* newBuf */
        start local 9 // io.netty.buffer.ByteBuf newBuf
        31: .line 138
            aload 8 /* publish */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
        32: .line 139
            aload 8 /* publish */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
        33: .line 140
            aload 8 /* publish */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.isDup:()Z
        34: .line 141
            aload 8 /* publish */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.isRetain:()Z
        35: .line 142
            aload 8 /* publish */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.topicName:()Ljava/lang/String;
        36: .line 143
            aload 9 /* newBuf */
        37: .line 137
            invokestatic io.vertx.mqtt.messages.MqttPublishMessage.create:(ILio/netty/handler/codec/mqtt/MqttQoS;ZZLjava/lang/String;Lio/netty/buffer/ByteBuf;)Lio/vertx/mqtt/messages/MqttPublishMessage;
            astore 10 /* mqttPublishMessage */
        start local 10 // io.vertx.mqtt.messages.MqttPublishMessage mqttPublishMessage
        38: .line 144
            aload 0 /* this */
            aload 10 /* mqttPublishMessage */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePublish:(Lio/vertx/mqtt/messages/MqttPublishMessage;)V
        39: .line 145
            goto 59
        end local 10 // io.vertx.mqtt.messages.MqttPublishMessage mqttPublishMessage
        end local 9 // io.netty.buffer.ByteBuf newBuf
        end local 8 // io.netty.handler.codec.mqtt.MqttPublishMessage publish
        40: .line 149
      StackMap locals:
      StackMap stack:
            aload 2 /* mqttMessage */
            checkcast io.netty.handler.codec.mqtt.MqttPubAckMessage
            astore 11 /* mqttPubackMessage */
        start local 11 // io.netty.handler.codec.mqtt.MqttPubAckMessage mqttPubackMessage
        41: .line 150
            aload 0 /* this */
            aload 11 /* mqttPubackMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttPubAckMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePuback:(I)V
        42: .line 151
            goto 59
        end local 11 // io.netty.handler.codec.mqtt.MqttPubAckMessage mqttPubackMessage
        43: .line 155
      StackMap locals:
      StackMap stack:
            aload 2 /* mqttMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
            istore 12 /* pubrecMessageId */
        start local 12 // int pubrecMessageId
        44: .line 156
            aload 0 /* this */
            iload 12 /* pubrecMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePubrec:(I)V
        45: .line 157
            goto 59
        end local 12 // int pubrecMessageId
        46: .line 161
      StackMap locals:
      StackMap stack:
            aload 2 /* mqttMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
            istore 13 /* pubrelMessageId */
        start local 13 // int pubrelMessageId
        47: .line 162
            aload 0 /* this */
            iload 13 /* pubrelMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePubrel:(I)V
        48: .line 163
            goto 59
        end local 13 // int pubrelMessageId
        49: .line 167
      StackMap locals:
      StackMap stack:
            aload 2 /* mqttMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
            istore 14 /* pubcompMessageId */
        start local 14 // int pubcompMessageId
        50: .line 168
            aload 0 /* this */
            iload 14 /* pubcompMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePubcomp:(I)V
        51: .line 169
            goto 59
        end local 14 // int pubcompMessageId
        52: .line 173
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePingreq:()V
        53: .line 174
            goto 59
        54: .line 178
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleDisconnect:()V
        55: .line 179
            goto 59
        56: .line 183
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            new java.lang.Exception
            dup
            new java.lang.StringBuilder
            dup
            ldc "Wrong MQTT message type "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* mqttMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.messageType:()Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
            invokeinterface io.netty.channel.ChannelHandlerContext.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelHandlerContext;
            pop
        end local 3 // io.netty.handler.codec.DecoderResult result
        end local 2 // io.netty.handler.codec.mqtt.MqttMessage mqttMessage
        57: .line 188
            goto 59
        58: .line 190
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            new java.lang.Exception
            dup
            new java.lang.StringBuilder
            dup
            ldc "Wrong message type "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* msg */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getName:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
            invokeinterface io.netty.channel.ChannelHandlerContext.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelHandlerContext;
            pop
        59: .line 192
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Object msg
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot                    Name  Signature
            0   60     0                    this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0   60     1                     msg  Ljava/lang/Object;
            2   57     2             mqttMessage  Lio/netty/handler/codec/mqtt/MqttMessage;
            3   57     3                  result  Lio/netty/handler/codec/DecoderResult;
            5   11     4                   cause  Ljava/lang/Throwable;
           18   23     4               subscribe  Lio/netty/handler/codec/mqtt/MqttSubscribeMessage;
           21   23     5    mqttSubscribeMessage  Lio/vertx/mqtt/messages/MqttSubscribeMessage;
           24   29     6             unsubscribe  Lio/netty/handler/codec/mqtt/MqttUnsubscribeMessage;
           27   29     7  mqttUnsubscribeMessage  Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;
           30   40     8                 publish  Lio/netty/handler/codec/mqtt/MqttPublishMessage;
           31   40     9                  newBuf  Lio/netty/buffer/ByteBuf;
           38   40    10      mqttPublishMessage  Lio/vertx/mqtt/messages/MqttPublishMessage;
           41   43    11       mqttPubackMessage  Lio/netty/handler/codec/mqtt/MqttPubAckMessage;
           44   46    12         pubrecMessageId  I
           47   49    13         pubrelMessageId  I
           50   52    14        pubcompMessageId  I
    MethodParameters:
      Name  Flags
      msg   

  private void handleConnect(io.netty.handler.codec.mqtt.MqttConnectMessage);
    descriptor: (Lio/netty/handler/codec/mqtt/MqttConnectMessage;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=11, locals=7, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // io.netty.handler.codec.mqtt.MqttConnectMessage msg
         0: .line 200
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            ifnull 3
         1: .line 202
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.close:()V
         2: .line 203
            return
         3: .line 208
      StackMap locals:
      StackMap stack:
            new io.vertx.mqtt.MqttWill
            dup
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.isWillFlag:()Z
         4: .line 209
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.willTopic:()Ljava/lang/String;
         5: .line 210
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.willMessageInBytes:()[B
            ifnull 6
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.willMessageInBytes:()[B
            invokestatic io.vertx.core.buffer.Buffer.buffer:([B)Lio/vertx/core/buffer/Buffer;
            goto 7
      StackMap locals: io.vertx.mqtt.impl.MqttServerConnection io.netty.handler.codec.mqtt.MqttConnectMessage
      StackMap stack: new 3 new 3 int java.lang.String
         6: aconst_null
         7: .line 211
      StackMap locals: io.vertx.mqtt.impl.MqttServerConnection io.netty.handler.codec.mqtt.MqttConnectMessage
      StackMap stack: new 3 new 3 int java.lang.String io.vertx.core.buffer.Buffer
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.willQos:()I
         8: .line 212
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.isWillRetain:()Z
         9: .line 208
            invokespecial io.vertx.mqtt.MqttWill.<init>:(ZLjava/lang/String;Lio/vertx/core/buffer/Buffer;IZ)V
        10: .line 207
            astore 2 /* will */
        start local 2 // io.vertx.mqtt.MqttWill will
        11: .line 215
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.hasUserName:()Z
            ifeq 18
        12: .line 216
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.hasPassword:()Z
            ifeq 18
        13: .line 217
            new io.vertx.mqtt.MqttAuth
            dup
        14: .line 218
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.userName:()Ljava/lang/String;
        15: .line 219
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.password:()Ljava/lang/String;
        16: .line 217
            invokespecial io.vertx.mqtt.MqttAuth.<init>:(Ljava/lang/String;Ljava/lang/String;)V
        17: .line 219
            goto 19
      StackMap locals: io.vertx.mqtt.MqttWill
      StackMap stack:
        18: aconst_null
        19: .line 215
      StackMap locals:
      StackMap stack: io.vertx.mqtt.MqttAuth
            astore 3 /* auth */
        start local 3 // io.vertx.mqtt.MqttAuth auth
        20: .line 222
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.clientIdentifier:()Ljava/lang/String;
            ifnull 23
        21: .line 223
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.clientIdentifier:()Ljava/lang/String;
            invokevirtual java.lang.String.isEmpty:()Z
            ifne 23
        22: .line 222
            iconst_0
            goto 24
      StackMap locals: io.vertx.mqtt.MqttAuth
      StackMap stack:
        23: iconst_1
      StackMap locals:
      StackMap stack: int
        24: istore 4 /* isZeroBytes */
        start local 4 // boolean isZeroBytes
        25: .line 225
            aconst_null
            astore 5 /* clientIdentifier */
        start local 5 // java.lang.String clientIdentifier
        26: .line 228
            iload 4 /* isZeroBytes */
            ifne 29
        27: .line 229
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.payload:()Lio/netty/handler/codec/mqtt/MqttConnectPayload;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectPayload.clientIdentifier:()Ljava/lang/String;
            astore 5 /* clientIdentifier */
        28: .line 230
            goto 31
      StackMap locals: int java.lang.String
      StackMap stack:
        29: aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.options:Lio/vertx/mqtt/MqttServerOptions;
            invokevirtual io.vertx.mqtt.MqttServerOptions.isAutoClientId:()Z
            ifeq 31
        30: .line 231
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            astore 5 /* clientIdentifier */
        31: .line 235
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
        32: .line 236
            new io.vertx.mqtt.impl.MqttEndpointImpl
            dup
        33: .line 237
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
        34: .line 238
            aload 5 /* clientIdentifier */
        35: .line 239
            aload 3 /* auth */
        36: .line 240
            aload 2 /* will */
        37: .line 241
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.isCleanSession:()Z
        38: .line 242
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.version:()I
        39: .line 243
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.name:()Ljava/lang/String;
        40: .line 244
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.keepAliveTimeSeconds:()I
        41: .line 236
            invokespecial io.vertx.mqtt.impl.MqttEndpointImpl.<init>:(Lio/vertx/core/net/impl/NetSocketInternal;Ljava/lang/String;Lio/vertx/mqtt/MqttAuth;Lio/vertx/mqtt/MqttWill;ZILjava/lang/String;I)V
        42: .line 235
            putfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
        43: .line 247
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            ldc "idle"
            invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
            pop
        44: .line 248
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            ldc "timeoutOnConnect"
            invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
            pop
        45: .line 251
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.keepAliveTimeSeconds:()I
            ifeq 49
        46: .line 255
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.keepAliveTimeSeconds:()I
            i2d
            ldc 1.5
            dmul
            invokestatic java.lang.Math.ceil:(D)D
            d2i
            istore 6 /* keepAliveTimeout */
        start local 6 // int keepAliveTimeout
        47: .line 258
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            ldc "handler"
            ldc "idle"
            new io.netty.handler.timeout.IdleStateHandler
            dup
            iload 6 /* keepAliveTimeout */
            iconst_0
            iconst_0
            invokespecial io.netty.handler.timeout.IdleStateHandler.<init>:(III)V
            invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
            pop
        48: .line 259
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
            invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
            ldc "handler"
            ldc "keepAliveHandler"
            new io.vertx.mqtt.impl.MqttServerConnection$1
            dup
            aload 0 /* this */
            invokespecial io.vertx.mqtt.impl.MqttServerConnection$1.<init>:(Lio/vertx/mqtt/impl/MqttServerConnection;)V
            invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
            pop
        end local 6 // int keepAliveTimeout
        49: .line 275
      StackMap locals:
      StackMap stack:
            iload 4 /* isZeroBytes */
            ifeq 54
            aload 1 /* msg */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.isCleanSession:()Z
            ifne 54
        50: .line 276
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.exceptionHandler:Lio/vertx/core/Handler;
            ifnull 52
        51: .line 277
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.exceptionHandler:Lio/vertx/core/Handler;
            new io.vertx.core.VertxException
            dup
            ldc "With zero-length client-id, clean session MUST be true"
            invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;)V
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        52: .line 279
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_REFUSED_IDENTIFIER_REJECTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.reject:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
        53: .line 280
            goto 57
        54: .line 283
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/mqtt/impl/MqttServerConnection;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/mqtt/impl/MqttServerConnection.lambda$0(Ljava/lang/Throwable;)V (7)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
        55: .line 288
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/mqtt/impl/MqttServerConnection;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/mqtt/impl/MqttServerConnection.lambda$1(Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
        56: .line 290
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpointHandler:Lio/vertx/core/Handler;
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        57: .line 292
      StackMap locals:
      StackMap stack:
            return
        end local 5 // java.lang.String clientIdentifier
        end local 4 // boolean isZeroBytes
        end local 3 // io.vertx.mqtt.MqttAuth auth
        end local 2 // io.vertx.mqtt.MqttWill will
        end local 1 // io.netty.handler.codec.mqtt.MqttConnectMessage msg
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   58     0              this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0   58     1               msg  Lio/netty/handler/codec/mqtt/MqttConnectMessage;
           11   58     2              will  Lio/vertx/mqtt/MqttWill;
           20   58     3              auth  Lio/vertx/mqtt/MqttAuth;
           25   58     4       isZeroBytes  Z
           26   58     5  clientIdentifier  Ljava/lang/String;
           47   49     6  keepAliveTimeout  I
    MethodParameters:
      Name  Flags
      msg   

  void handleSubscribe(io.vertx.mqtt.messages.MqttSubscribeMessage);
    descriptor: (Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // io.vertx.mqtt.messages.MqttSubscribeMessage msg
         0: .line 301
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 302
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 303
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            aload 1 /* msg */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handleSubscribe:(Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V
         3: .line 301
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 306
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.mqtt.messages.MqttSubscribeMessage msg
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    8     1   msg  Lio/vertx/mqtt/messages/MqttSubscribeMessage;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
      Name  Flags
      msg   

  void handleUnsubscribe(io.vertx.mqtt.messages.MqttUnsubscribeMessage);
    descriptor: (Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // io.vertx.mqtt.messages.MqttUnsubscribeMessage msg
         0: .line 315
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 316
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 317
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            aload 1 /* msg */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handleUnsubscribe:(Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V
         3: .line 315
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 320
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.mqtt.messages.MqttUnsubscribeMessage msg
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    8     1   msg  Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
      Name  Flags
      msg   

  void handlePublish(io.vertx.mqtt.messages.MqttPublishMessage);
    descriptor: (Lio/vertx/mqtt/messages/MqttPublishMessage;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // io.vertx.mqtt.messages.MqttPublishMessage msg
         0: .line 329
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 330
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 331
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            aload 1 /* msg */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handlePublish:(Lio/vertx/mqtt/messages/MqttPublishMessage;)V
         3: .line 329
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 334
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.mqtt.messages.MqttPublishMessage msg
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    8     1   msg  Lio/vertx/mqtt/messages/MqttPublishMessage;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
      Name  Flags
      msg   

  void handlePuback(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // int pubackMessageId
         0: .line 343
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 344
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 345
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            iload 1 /* pubackMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handlePuback:(I)V
         3: .line 343
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 348
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubackMessageId
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    8     0             this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    8     1  pubackMessageId  I
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
                 Name  Flags
      pubackMessageId  

  void handlePubrec(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // int pubrecMessageId
         0: .line 357
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 358
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 359
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            iload 1 /* pubrecMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handlePubrec:(I)V
         3: .line 357
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 362
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubrecMessageId
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    8     0             this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    8     1  pubrecMessageId  I
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
                 Name  Flags
      pubrecMessageId  

  void handlePubrel(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // int pubrelMessageId
         0: .line 371
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 372
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 373
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            iload 1 /* pubrelMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handlePubrel:(I)V
         3: .line 371
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 376
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubrelMessageId
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    8     0             this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    8     1  pubrelMessageId  I
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
                 Name  Flags
      pubrelMessageId  

  void handlePubcomp(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // int pubcompMessageId
         0: .line 385
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 386
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 387
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            iload 1 /* pubcompMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handlePubcomp:(I)V
         3: .line 385
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 390
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubcompMessageId
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    8     0              this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    8     1  pubcompMessageId  I
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
                  Name  Flags
      pubcompMessageId  

  void handlePingreq();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
         0: .line 397
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 398
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 399
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handlePingreq:()V
         3: .line 397
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 1
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 1
            monitorexit
         6: athrow
         7: .line 402
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any

  void handleDisconnect();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
         0: .line 409
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 410
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 411
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handleDisconnect:()V
         3: .line 409
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 1
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 1
            monitorexit
         6: athrow
         7: .line 414
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any

  private boolean checkConnected();
    descriptor: ()Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
         0: .line 423
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 424
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            ifnull 4
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:()Z
            ifeq 4
         2: .line 425
            aload 1
            monitorexit
         3: iconst_1
            ireturn
         4: .line 427
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/net/impl/NetSocketInternal;
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.close:()Lio/vertx/core/Future;
            pop
         5: .line 428
            new java.lang.IllegalStateException
            dup
            ldc "Received an MQTT packet from a not connected client (CONNECT not sent yet)"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 423
      StackMap locals:
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         7: athrow
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
      Exception table:
        from    to  target  type
           1     3       6  any
           4     7       6  any

  static int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 49
            getstatic io.vertx.mqtt.impl.MqttServerConnection.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic io.netty.handler.codec.mqtt.MqttMessageType.values:()[Lio/netty/handler/codec/mqtt/MqttMessageType;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.CONNACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            iconst_2
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.CONNECT:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            iconst_1
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.DISCONNECT:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 14
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PINGREQ:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 12
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PINGRESP:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 13
            iastore
        15: goto 17
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        16: pop
      StackMap locals:
      StackMap stack:
        17: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            iconst_4
            iastore
        18: goto 20
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        19: pop
      StackMap locals:
      StackMap stack:
        20: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBCOMP:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 7
            iastore
        21: goto 23
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        22: pop
      StackMap locals:
      StackMap stack:
        23: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBLISH:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            iconst_3
            iastore
        24: goto 26
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        25: pop
      StackMap locals:
      StackMap stack:
        26: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREC:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            iconst_5
            iastore
        27: goto 29
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        28: pop
      StackMap locals:
      StackMap stack:
        29: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREL:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 6
            iastore
        30: goto 32
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        31: pop
      StackMap locals:
      StackMap stack:
        32: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.SUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 9
            iastore
        33: goto 35
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        34: pop
      StackMap locals:
      StackMap stack:
        35: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.SUBSCRIBE:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 8
            iastore
        36: goto 38
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        37: pop
      StackMap locals:
      StackMap stack:
        38: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.UNSUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 11
            iastore
        39: goto 41
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        40: pop
      StackMap locals:
      StackMap stack:
        41: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.UNSUBSCRIBE:Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            bipush 10
            iastore
        42: goto 44
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        43: pop
      StackMap locals:
      StackMap stack:
        44: aload 0
            dup
            putstatic io.vertx.mqtt.impl.MqttServerConnection.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:[I
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.NoSuchFieldError
           5     6       7  Class java.lang.NoSuchFieldError
           8     9      10  Class java.lang.NoSuchFieldError
          11    12      13  Class java.lang.NoSuchFieldError
          14    15      16  Class java.lang.NoSuchFieldError
          17    18      19  Class java.lang.NoSuchFieldError
          20    21      22  Class java.lang.NoSuchFieldError
          23    24      25  Class java.lang.NoSuchFieldError
          26    27      28  Class java.lang.NoSuchFieldError
          29    30      31  Class java.lang.NoSuchFieldError
          32    33      34  Class java.lang.NoSuchFieldError
          35    36      37  Class java.lang.NoSuchFieldError
          38    39      40  Class java.lang.NoSuchFieldError
          41    42      43  Class java.lang.NoSuchFieldError

  private void lambda$0(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // java.lang.Throwable t
         0: .line 284
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            aload 1 /* t */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handleException:(Ljava/lang/Throwable;)V
         1: .line 285
            return
        end local 1 // java.lang.Throwable t
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    2     1     t  Ljava/lang/Throwable;

  private void lambda$1(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // java.lang.Void v
         0: .line 288
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.handleClosed:()V
            return
        end local 1 // java.lang.Void v
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    1     1     v  Ljava/lang/Void;
}
SourceFile: "MqttServerConnection.java"
NestMembers:
  io.vertx.mqtt.impl.MqttServerConnection$1
InnerClasses:
  io.vertx.mqtt.impl.MqttServerConnection$1
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
/

io.vertx/ vertx-mqtt/ 4.0.0/ io/vertx/mqtt/impl/MqttServerConnection.class
