io.vertx/vertx-mqtt/3.8.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.logging.Logger log;
    descriptor: Lio/vertx/core/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.impl.NetSocketInternal so;
    descriptor: Lio/vertx/core/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 50
            ldc Lio/vertx/mqtt/impl/MqttServerConnection;
            invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
            putstatic io.vertx.mqtt.impl.MqttServerConnection.log:Lio/vertx/core/logging/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void init(io.vertx.core.Handler<io.vertx.mqtt.MqttEndpoint>, io.vertx.core.Handler<java.lang.Throwable>);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // io.vertx.core.Handler endpointHandler
        start local 2 // io.vertx.core.Handler rejectHandler
         0: .line 66
            aload 0 /* this */
            aload 1 /* endpointHandler */
            putfield io.vertx.mqtt.impl.MqttServerConnection.endpointHandler:Lio/vertx/core/Handler;
         1: .line 67
            aload 0 /* this */
            aload 2 /* rejectHandler */
            putfield io.vertx.mqtt.impl.MqttServerConnection.exceptionHandler:Lio/vertx/core/Handler;
         2: .line 68
            return
        end local 2 // io.vertx.core.Handler rejectHandler
        end local 1 // io.vertx.core.Handler endpointHandler
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    3     1  endpointHandler  Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;
            0    3     2    rejectHandler  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)V
    MethodParameters:
                 Name  Flags
      endpointHandler  
      rejectHandler    

  public void <init>(io.vertx.core.impl.NetSocketInternal, io.vertx.mqtt.MqttServerOptions);
    descriptor: (Lio/vertx/core/impl/NetSocketInternal;Lio/vertx/mqtt/MqttServerOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.mqtt.impl.MqttServerConnection this
        start local 1 // io.vertx.core.impl.NetSocketInternal so
        start local 2 // io.vertx.mqtt.MqttServerOptions options
         0: .line 70
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 71
            aload 0 /* this */
            aload 1 /* so */
            putfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
         2: .line 72
            aload 0 /* this */
            aload 1 /* so */
            invokeinterface io.vertx.core.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
            putfield io.vertx.mqtt.impl.MqttServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
         3: .line 73
            aload 0 /* this */
            aload 2 /* options */
            putfield io.vertx.mqtt.impl.MqttServerConnection.options:Lio/vertx/mqtt/MqttServerOptions;
         4: .line 74
            return
        end local 2 // io.vertx.mqtt.MqttServerOptions options
        end local 1 // io.vertx.core.impl.NetSocketInternal so
        end local 0 // io.vertx.mqtt.impl.MqttServerConnection this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0    5     1       so  Lio/vertx/core/impl/NetSocketInternal;
            0    5     2  options  Lio/vertx/mqtt/MqttServerOptions;
    MethodParameters:
         Name  Flags
      so       
      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 85
            aload 1 /* msg */
            instanceof io.netty.handler.codec.mqtt.MqttMessage
            ifeq 58
         1: .line 87
            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 89
            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 90
            aload 3 /* result */
            invokevirtual io.netty.handler.codec.DecoderResult.isFailure:()Z
            ifeq 11
         4: .line 91
            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 92
            aload 4 /* cause */
            instanceof io.netty.handler.codec.mqtt.MqttUnacceptableProtocolVersionException
            ifeq 9
         6: .line 93
            aload 0 /* this */
            new io.vertx.mqtt.impl.MqttEndpointImpl
            dup
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/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/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 94
            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 95
            goto 10
         9: .line 96
      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 98
      StackMap locals:
      StackMap stack:
            return
        end local 4 // java.lang.Throwable cause
        11: .line 100
      StackMap locals:
      StackMap stack:
            aload 3 /* result */
            invokevirtual io.netty.handler.codec.DecoderResult.isFinished:()Z
            ifne 14
        12: .line 101
            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 102
            return
        14: .line 105
      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 108
      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 109
            goto 59
        17: .line 113
      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 116
            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 117
            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 115
            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 118
            aload 0 /* this */
            aload 5 /* mqttSubscribeMessage */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleSubscribe:(Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V
        22: .line 119
            goto 59
        end local 5 // io.vertx.mqtt.messages.MqttSubscribeMessage mqttSubscribeMessage
        end local 4 // io.netty.handler.codec.mqtt.MqttSubscribeMessage subscribe
        23: .line 123
      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 126
            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 127
            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 125
            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 128
            aload 0 /* this */
            aload 7 /* mqttUnsubscribeMessage */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleUnsubscribe:(Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V
        28: .line 129
            goto 59
        end local 7 // io.vertx.mqtt.messages.MqttUnsubscribeMessage mqttUnsubscribeMessage
        end local 6 // io.netty.handler.codec.mqtt.MqttUnsubscribeMessage unsubscribe
        29: .line 133
      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 134
            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 137
            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 138
            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 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.isDup:()Z
        34: .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.isRetain:()Z
        35: .line 141
            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 142
            aload 9 /* newBuf */
        37: .line 136
            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 143
            aload 0 /* this */
            aload 10 /* mqttPublishMessage */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePublish:(Lio/vertx/mqtt/messages/MqttPublishMessage;)V
        39: .line 144
            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 148
      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 149
            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 150
            goto 59
        end local 11 // io.netty.handler.codec.mqtt.MqttPubAckMessage mqttPubackMessage
        43: .line 154
      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 155
            aload 0 /* this */
            iload 12 /* pubrecMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePubrec:(I)V
        45: .line 156
            goto 59
        end local 12 // int pubrecMessageId
        46: .line 160
      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 161
            aload 0 /* this */
            iload 13 /* pubrelMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePubrel:(I)V
        48: .line 162
            goto 59
        end local 13 // int pubrelMessageId
        49: .line 166
      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 167
            aload 0 /* this */
            iload 14 /* pubcompMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePubcomp:(I)V
        51: .line 168
            goto 59
        end local 14 // int pubcompMessageId
        52: .line 172
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handlePingreq:()V
        53: .line 173
            goto 59
        54: .line 177
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleDisconnect:()V
        55: .line 178
            goto 59
        56: .line 182
      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 187
            goto 59
        58: .line 189
      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 191
      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 199
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
            ifnull 3
         1: .line 201
            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 202
            return
         3: .line 207
      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 208
            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 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.willMessageInBytes:()[B
         6: .line 210
            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
         7: .line 211
            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
         8: .line 207
            invokespecial io.vertx.mqtt.MqttWill.<init>:(ZLjava/lang/String;[BIZ)V
         9: .line 206
            astore 2 /* will */
        start local 2 // io.vertx.mqtt.MqttWill will
        10: .line 214
            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 17
        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.hasPassword:()Z
            ifeq 17
        12: .line 216
            new io.vertx.mqtt.MqttAuth
            dup
        13: .line 217
            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;
        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.password:()Ljava/lang/String;
        15: .line 216
            invokespecial io.vertx.mqtt.MqttAuth.<init>:(Ljava/lang/String;Ljava/lang/String;)V
        16: .line 218
            goto 18
      StackMap locals: io.vertx.mqtt.MqttWill
      StackMap stack:
        17: aconst_null
        18: .line 214
      StackMap locals:
      StackMap stack: io.vertx.mqtt.MqttAuth
            astore 3 /* auth */
        start local 3 // io.vertx.mqtt.MqttAuth auth
        19: .line 221
            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 22
        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;
            invokevirtual java.lang.String.isEmpty:()Z
            ifne 22
        21: .line 221
            iconst_0
            goto 23
      StackMap locals: io.vertx.mqtt.MqttAuth
      StackMap stack:
        22: iconst_1
      StackMap locals:
      StackMap stack: int
        23: istore 4 /* isZeroBytes */
        start local 4 // boolean isZeroBytes
        24: .line 224
            aconst_null
            astore 5 /* clientIdentifier */
        start local 5 // java.lang.String clientIdentifier
        25: .line 227
            iload 4 /* isZeroBytes */
            ifne 28
        26: .line 228
            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 */
        27: .line 229
            goto 30
      StackMap locals: int java.lang.String
      StackMap stack:
        28: aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.options:Lio/vertx/mqtt/MqttServerOptions;
            invokevirtual io.vertx.mqtt.MqttServerOptions.isAutoClientId:()Z
            ifeq 30
        29: .line 230
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            astore 5 /* clientIdentifier */
        30: .line 234
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
        31: .line 235
            new io.vertx.mqtt.impl.MqttEndpointImpl
            dup
        32: .line 236
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
        33: .line 237
            aload 5 /* clientIdentifier */
        34: .line 238
            aload 3 /* auth */
        35: .line 239
            aload 2 /* will */
        36: .line 240
            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
        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.version:()I
        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.name:()Ljava/lang/String;
        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.keepAliveTimeSeconds:()I
        40: .line 235
            invokespecial io.vertx.mqtt.impl.MqttEndpointImpl.<init>:(Lio/vertx/core/impl/NetSocketInternal;Ljava/lang/String;Lio/vertx/mqtt/MqttAuth;Lio/vertx/mqtt/MqttWill;ZILjava/lang/String;I)V
        41: .line 234
            putfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
        42: .line 246
            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
        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 "timeoutOnConnect"
            invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
            pop
        44: .line 250
            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 50
        45: .line 253
            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
        46: .line 254
            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
            iconst_2
            idiv
        47: .line 253
            iadd
            istore 6 /* timeout */
        start local 6 // int timeout
        48: .line 257
            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 /* timeout */
            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
        49: .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 "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 timeout
        50: .line 274
      StackMap locals:
      StackMap stack:
            iload 4 /* isZeroBytes */
            ifeq 55
            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 55
        51: .line 275
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.exceptionHandler:Lio/vertx/core/Handler;
            ifnull 53
        52: .line 276
            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
        53: .line 278
      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
        54: .line 279
            goto 58
        55: .line 282
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/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.impl.NetSocketInternal.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
        56: .line 287
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/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.impl.NetSocketInternal.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
        57: .line 289
            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
        58: .line 291
      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   59     0              this  Lio/vertx/mqtt/impl/MqttServerConnection;
            0   59     1               msg  Lio/netty/handler/codec/mqtt/MqttConnectMessage;
           10   59     2              will  Lio/vertx/mqtt/MqttWill;
           19   59     3              auth  Lio/vertx/mqtt/MqttAuth;
           24   59     4       isZeroBytes  Z
           25   59     5  clientIdentifier  Ljava/lang/String;
           48   50     6           timeout  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 300
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 301
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 302
            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 300
      StackMap locals: io.vertx.core.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 305
      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 314
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 315
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 316
            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 314
      StackMap locals: io.vertx.core.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 319
      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 328
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 329
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 330
            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 328
      StackMap locals: io.vertx.core.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 333
      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 342
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 343
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 344
            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 342
      StackMap locals: io.vertx.core.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 347
      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 356
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 357
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 358
            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 356
      StackMap locals: io.vertx.core.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 361
      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 370
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 371
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 372
            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 370
      StackMap locals: io.vertx.core.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 375
      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 384
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 385
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 386
            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 384
      StackMap locals: io.vertx.core.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 389
      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 396
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 397
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 398
            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 396
      StackMap locals: io.vertx.core.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 401
      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 408
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 409
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttServerConnection.checkConnected:()Z
            ifeq 3
         2: .line 410
            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 408
      StackMap locals: io.vertx.core.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 413
      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 422
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 423
            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 424
            aload 1
            monitorexit
         3: iconst_1
            ireturn
         4: .line 426
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttServerConnection.so:Lio/vertx/core/impl/NetSocketInternal;
            invokeinterface io.vertx.core.impl.NetSocketInternal.close:()V
         5: .line 427
            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 422
      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 48
            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 283
            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 284
            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 287
            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/ 3.8.0/ io/vertx/mqtt/impl/MqttServerConnection.class
