io.netty/netty-all/4.1.25.Final : io/netty/handler/codec/mqtt/MqttDecoder.class

MqttDecoder
http://netty.io/netty-all/: Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers and clients. (The Netty Project)
Apache License, Version 2.0
The Netty Project Contributors (The Netty Project)
public final class io.netty.handler.codec.mqtt.MqttDecoder extends io.netty.handler.codec.ReplayingDecoder<io.netty.handler.codec.mqtt.MqttDecoder$DecoderState>
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.netty.handler.codec.mqtt.MqttDecoder
  super_class: io.netty.handler.codec.ReplayingDecoder
{
  private static final int DEFAULT_MAX_BYTES_IN_MESSAGE;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 8092

  private io.netty.handler.codec.mqtt.MqttFixedHeader mqttFixedHeader;
    descriptor: Lio/netty/handler/codec/mqtt/MqttFixedHeader;
    flags: (0x0002) ACC_PRIVATE

  private java.lang.Object variableHeader;
    descriptor: Ljava/lang/Object;
    flags: (0x0002) ACC_PRIVATE

  private int bytesRemainingInVariablePart;
    descriptor: I
    flags: (0x0002) ACC_PRIVATE

  private final int maxBytesInMessage;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

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

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
         0: .line 63
            aload 0 /* this */
            sipush 8092
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder.<init>:(I)V
         1: .line 64
            return
        end local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/netty/handler/codec/mqtt/MqttDecoder;

  public void <init>(int);
    descriptor: (I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
        start local 1 // int maxBytesInMessage
         0: .line 67
            aload 0 /* this */
            getstatic io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.READ_FIXED_HEADER:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokespecial io.netty.handler.codec.ReplayingDecoder.<init>:(Ljava/lang/Object;)V
         1: .line 68
            aload 0 /* this */
            iload 1 /* maxBytesInMessage */
            putfield io.netty.handler.codec.mqtt.MqttDecoder.maxBytesInMessage:I
         2: .line 69
            return
        end local 1 // int maxBytesInMessage
        end local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    3     0               this  Lio/netty/handler/codec/mqtt/MqttDecoder;
            0    3     1  maxBytesInMessage  I
    MethodParameters:
                   Name  Flags
      maxBytesInMessage  

  protected void decode(io.netty.channel.ChannelHandlerContext, io.netty.buffer.ByteBuf, java.util.List<java.lang.Object>);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;Ljava/util/List;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=6, args_size=4
        start local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // io.netty.buffer.ByteBuf buffer
        start local 3 // java.util.List out
         0: .line 73
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttDecoder$DecoderState:()[I
            aload 0 /* this */
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.state:()Ljava/lang/Object;
            checkcast io.netty.handler.codec.mqtt.MqttDecoder$DecoderState
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.ordinal:()I
            iaload
            tableswitch { // 1 - 4
                    1: 1
                    2: 8
                    3: 18
                    4: 41
              default: 43
          }
         1: .line 75
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeFixedHeader:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            putfield io.netty.handler.codec.mqtt.MqttDecoder.mqttFixedHeader:Lio/netty/handler/codec/mqtt/MqttFixedHeader;
         2: .line 76
            aload 0 /* this */
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.mqttFixedHeader:Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.remainingLength:()I
            putfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
         3: .line 77
            aload 0 /* this */
            getstatic io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.READ_VARIABLE_HEADER:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.checkpoint:(Ljava/lang/Object;)V
         4: .line 79
            goto 8
      StackMap locals:
      StackMap stack: java.lang.Exception
         5: astore 4 /* cause */
        start local 4 // java.lang.Exception cause
         6: .line 80
            aload 3 /* out */
            aload 0 /* this */
            aload 4 /* cause */
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.invalidMessage:(Ljava/lang/Throwable;)Lio/netty/handler/codec/mqtt/MqttMessage;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         7: .line 81
            return
        end local 4 // java.lang.Exception cause
         8: .line 85
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.maxBytesInMessage:I
            if_icmple 10
         9: .line 86
            new io.netty.handler.codec.DecoderException
            dup
            new java.lang.StringBuilder
            dup
            ldc "too large message: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " bytes"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial io.netty.handler.codec.DecoderException.<init>:(Ljava/lang/String;)V
            athrow
        10: .line 88
      StackMap locals:
      StackMap stack:
            aload 2 /* buffer */
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.mqttFixedHeader:Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeVariableHeader:(Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 4 /* decodedVariableHeader */
        start local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedVariableHeader
        11: .line 89
            aload 0 /* this */
            aload 4 /* decodedVariableHeader */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            putfield io.netty.handler.codec.mqtt.MqttDecoder.variableHeader:Ljava/lang/Object;
        12: .line 90
            aload 0 /* this */
            dup
            getfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
            aload 4 /* decodedVariableHeader */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            isub
            putfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
        13: .line 91
            aload 0 /* this */
            getstatic io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.READ_PAYLOAD:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.checkpoint:(Ljava/lang/Object;)V
        end local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedVariableHeader
        14: .line 93
            goto 18
      StackMap locals:
      StackMap stack: java.lang.Exception
        15: astore 4 /* cause */
        start local 4 // java.lang.Exception cause
        16: .line 94
            aload 3 /* out */
            aload 0 /* this */
            aload 4 /* cause */
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.invalidMessage:(Ljava/lang/Throwable;)Lio/netty/handler/codec/mqtt/MqttMessage;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        17: .line 95
            return
        end local 4 // java.lang.Exception cause
        18: .line 101
      StackMap locals:
      StackMap stack:
            aload 2 /* buffer */
        19: .line 102
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.mqttFixedHeader:Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.messageType:()Lio/netty/handler/codec/mqtt/MqttMessageType;
        20: .line 103
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
        21: .line 104
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.variableHeader:Ljava/lang/Object;
        22: .line 100
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodePayload:(Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttMessageType;ILjava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
        23: .line 99
            astore 4 /* decodedPayload */
        start local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedPayload
        24: .line 105
            aload 0 /* this */
            dup
            getfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
            aload 4 /* decodedPayload */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            isub
            putfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
        25: .line 106
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
            ifeq 31
        26: .line 107
            new io.netty.handler.codec.DecoderException
            dup
        27: .line 108
            new java.lang.StringBuilder
            dup
            ldc "non-zero remaining payload bytes: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
        28: .line 109
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.bytesRemainingInVariablePart:I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " ("
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.mqttFixedHeader: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;
            bipush 41
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
        29: .line 108
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        30: .line 107
            invokespecial io.netty.handler.codec.DecoderException.<init>:(Ljava/lang/String;)V
            athrow
        31: .line 111
      StackMap locals: io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack:
            aload 0 /* this */
            getstatic io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.READ_FIXED_HEADER:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.checkpoint:(Ljava/lang/Object;)V
        32: .line 113
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.mqttFixedHeader:Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            aload 0 /* this */
            getfield io.netty.handler.codec.mqtt.MqttDecoder.variableHeader:Ljava/lang/Object;
            aload 4 /* decodedPayload */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
        33: .line 112
            invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
            astore 5 /* message */
        start local 5 // io.netty.handler.codec.mqtt.MqttMessage message
        34: .line 114
            aload 0 /* this */
            aconst_null
            putfield io.netty.handler.codec.mqtt.MqttDecoder.mqttFixedHeader:Lio/netty/handler/codec/mqtt/MqttFixedHeader;
        35: .line 115
            aload 0 /* this */
            aconst_null
            putfield io.netty.handler.codec.mqtt.MqttDecoder.variableHeader:Ljava/lang/Object;
        36: .line 116
            aload 3 /* out */
            aload 5 /* message */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        37: .line 117
            goto 44
        end local 5 // io.netty.handler.codec.mqtt.MqttMessage message
        end local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedPayload
        38: .line 118
      StackMap locals: io.netty.handler.codec.mqtt.MqttDecoder io.netty.channel.ChannelHandlerContext io.netty.buffer.ByteBuf java.util.List
      StackMap stack: java.lang.Exception
            astore 4 /* cause */
        start local 4 // java.lang.Exception cause
        39: .line 119
            aload 3 /* out */
            aload 0 /* this */
            aload 4 /* cause */
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.invalidMessage:(Ljava/lang/Throwable;)Lio/netty/handler/codec/mqtt/MqttMessage;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        40: .line 120
            return
        end local 4 // java.lang.Exception cause
        41: .line 125
      StackMap locals:
      StackMap stack:
            aload 2 /* buffer */
            aload 0 /* this */
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.actualReadableBytes:()I
            invokevirtual io.netty.buffer.ByteBuf.skipBytes:(I)Lio/netty/buffer/ByteBuf;
            pop
        42: .line 126
            goto 44
        43: .line 130
      StackMap locals:
      StackMap stack:
            new java.lang.Error
            dup
            invokespecial java.lang.Error.<init>:()V
            athrow
        44: .line 132
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.util.List out
        end local 2 // io.netty.buffer.ByteBuf buffer
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0   45     0                   this  Lio/netty/handler/codec/mqtt/MqttDecoder;
            0   45     1                    ctx  Lio/netty/channel/ChannelHandlerContext;
            0   45     2                 buffer  Lio/netty/buffer/ByteBuf;
            0   45     3                    out  Ljava/util/List<Ljava/lang/Object;>;
            6    8     4                  cause  Ljava/lang/Exception;
           11   14     4  decodedVariableHeader  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<*>;
           16   18     4                  cause  Ljava/lang/Exception;
           24   38     4         decodedPayload  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<*>;
           34   38     5                message  Lio/netty/handler/codec/mqtt/MqttMessage;
           39   41     4                  cause  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           1     4       5  Class java.lang.Exception
           8    14      15  Class java.lang.Exception
          18    37      38  Class java.lang.Exception
    Exceptions:
      throws java.lang.Exception
    Signature: (Lio/netty/channel/ChannelHandlerContext;Lio/netty/buffer/ByteBuf;Ljava/util/List<Ljava/lang/Object;>;)V
    MethodParameters:
        Name  Flags
      ctx     
      buffer  
      out     

  private io.netty.handler.codec.mqtt.MqttMessage invalidMessage(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Lio/netty/handler/codec/mqtt/MqttMessage;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
        start local 1 // java.lang.Throwable cause
         0: .line 135
            aload 0 /* this */
            getstatic io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.BAD_MESSAGE:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder.checkpoint:(Ljava/lang/Object;)V
         1: .line 136
            aload 1 /* cause */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newInvalidMessage:(Ljava/lang/Throwable;)Lio/netty/handler/codec/mqtt/MqttMessage;
            areturn
        end local 1 // java.lang.Throwable cause
        end local 0 // io.netty.handler.codec.mqtt.MqttDecoder this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/netty/handler/codec/mqtt/MqttDecoder;
            0    2     1  cause  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      cause  

  private static io.netty.handler.codec.mqtt.MqttFixedHeader decodeFixedHeader(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttFixedHeader;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=7, locals=11, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 146
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            istore 1 /* b1 */
        start local 1 // short b1
         1: .line 148
            iload 1 /* b1 */
            iconst_4
            ishr
            invokestatic io.netty.handler.codec.mqtt.MqttMessageType.valueOf:(I)Lio/netty/handler/codec/mqtt/MqttMessageType;
            astore 2 /* messageType */
        start local 2 // io.netty.handler.codec.mqtt.MqttMessageType messageType
         2: .line 149
            iload 1 /* b1 */
            bipush 8
            iand
            bipush 8
            if_icmpne 3
            iconst_1
            goto 4
      StackMap locals: int io.netty.handler.codec.mqtt.MqttMessageType
      StackMap stack:
         3: iconst_0
      StackMap locals:
      StackMap stack: int
         4: istore 3 /* dupFlag */
        start local 3 // boolean dupFlag
         5: .line 150
            iload 1 /* b1 */
            bipush 6
            iand
            iconst_1
            ishr
            istore 4 /* qosLevel */
        start local 4 // int qosLevel
         6: .line 151
            iload 1 /* b1 */
            iconst_1
            iand
            ifeq 7
            iconst_1
            goto 8
      StackMap locals: int int
      StackMap stack:
         7: iconst_0
      StackMap locals:
      StackMap stack: int
         8: istore 5 /* retain */
        start local 5 // boolean retain
         9: .line 153
            iconst_0
            istore 6 /* remainingLength */
        start local 6 // int remainingLength
        10: .line 154
            iconst_1
            istore 7 /* multiplier */
        start local 7 // int multiplier
        11: .line 156
            iconst_0
            istore 9 /* loops */
        start local 9 // int loops
        12: .line 158
      StackMap locals: io.netty.buffer.ByteBuf int io.netty.handler.codec.mqtt.MqttMessageType int int int int int top int
      StackMap stack:
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            istore 8 /* digit */
        start local 8 // short digit
        13: .line 159
            iload 6 /* remainingLength */
            iload 8 /* digit */
            bipush 127
            iand
            iload 7 /* multiplier */
            imul
            iadd
            istore 6 /* remainingLength */
        14: .line 160
            iload 7 /* multiplier */
            sipush 128
            imul
            istore 7 /* multiplier */
        15: .line 161
            iinc 9 /* loops */ 1
        16: .line 162
            iload 8 /* digit */
            sipush 128
            iand
            ifeq 18
            iload 9 /* loops */
            iconst_4
        17: .line 157
            if_icmplt 12
        18: .line 165
      StackMap locals: io.netty.buffer.ByteBuf int io.netty.handler.codec.mqtt.MqttMessageType int int int int int int int
      StackMap stack:
            iload 9 /* loops */
            iconst_4
            if_icmpne 20
            iload 8 /* digit */
            sipush 128
            iand
            ifeq 20
        19: .line 166
            new io.netty.handler.codec.DecoderException
            dup
            new java.lang.StringBuilder
            dup
            ldc "remaining length exceeds 4 digits ("
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* messageType */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            bipush 41
            invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial io.netty.handler.codec.DecoderException.<init>:(Ljava/lang/String;)V
            athrow
        20: .line 169
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            aload 2 /* messageType */
            iload 3 /* dupFlag */
            iload 4 /* qosLevel */
            invokestatic io.netty.handler.codec.mqtt.MqttQoS.valueOf:(I)Lio/netty/handler/codec/mqtt/MqttQoS;
            iload 5 /* retain */
            iload 6 /* remainingLength */
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
        21: .line 168
            astore 10 /* decodedFixedHeader */
        start local 10 // io.netty.handler.codec.mqtt.MqttFixedHeader decodedFixedHeader
        22: .line 170
            aload 10 /* decodedFixedHeader */
            invokestatic io.netty.handler.codec.mqtt.MqttCodecUtil.resetUnusedFields:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokestatic io.netty.handler.codec.mqtt.MqttCodecUtil.validateFixedHeader:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            areturn
        end local 10 // io.netty.handler.codec.mqtt.MqttFixedHeader decodedFixedHeader
        end local 9 // int loops
        end local 8 // short digit
        end local 7 // int multiplier
        end local 6 // int remainingLength
        end local 5 // boolean retain
        end local 4 // int qosLevel
        end local 3 // boolean dupFlag
        end local 2 // io.netty.handler.codec.mqtt.MqttMessageType messageType
        end local 1 // short b1
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   23     0              buffer  Lio/netty/buffer/ByteBuf;
            1   23     1                  b1  S
            2   23     2         messageType  Lio/netty/handler/codec/mqtt/MqttMessageType;
            5   23     3             dupFlag  Z
            6   23     4            qosLevel  I
            9   23     5              retain  Z
           10   23     6     remainingLength  I
           11   23     7          multiplier  I
           13   23     8               digit  S
           12   23     9               loops  I
           22   23    10  decodedFixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<?> decodeVariableHeader(io.netty.buffer.ByteBuf, io.netty.handler.codec.mqtt.MqttFixedHeader);
    descriptor: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // io.netty.handler.codec.mqtt.MqttFixedHeader mqttFixedHeader
         0: .line 180
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:()[I
            aload 1 /* 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: 1
                    2: 2
                    3: 4
                    4: 3
                    5: 3
                    6: 3
                    7: 3
                    8: 3
                    9: 3
                   10: 3
                   11: 3
                   12: 5
                   13: 5
                   14: 5
              default: 6
          }
         1: .line 182
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeConnectionVariableHeader:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         2: .line 185
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeConnAckVariableHeader:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         3: .line 195
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMessageIdVariableHeader:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         4: .line 198
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            aload 1 /* mqttFixedHeader */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodePublishVariableHeader:(Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         5: .line 204
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aconst_null
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
         6: .line 206
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aconst_null
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 1 // io.netty.handler.codec.mqtt.MqttFixedHeader mqttFixedHeader
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    7     0           buffer  Lio/netty/buffer/ByteBuf;
            0    7     1  mqttFixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
    Signature: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<*>;
    MethodParameters:
                 Name  Flags
      buffer           
      mqttFixedHeader  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttConnectVariableHeader> decodeConnectionVariableHeader(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=11, locals=14, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 210
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 1 /* protoString */
        start local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result protoString
         1: .line 211
            aload 1 /* protoString */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            istore 2 /* numberOfBytesConsumed */
        start local 2 // int numberOfBytesConsumed
         2: .line 213
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readByte:()B
            istore 3 /* protocolLevel */
        start local 3 // byte protocolLevel
         3: .line 214
            iinc 2 /* numberOfBytesConsumed */ 1
         4: .line 216
            aload 1 /* protoString */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            iload 3 /* protocolLevel */
            invokestatic io.netty.handler.codec.mqtt.MqttVersion.fromProtocolNameAndLevel:(Ljava/lang/String;B)Lio/netty/handler/codec/mqtt/MqttVersion;
            astore 4 /* mqttVersion */
        start local 4 // io.netty.handler.codec.mqtt.MqttVersion mqttVersion
         5: .line 218
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            istore 5 /* b1 */
        start local 5 // int b1
         6: .line 219
            iinc 2 /* numberOfBytesConsumed */ 1
         7: .line 221
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 6 /* keepAlive */
        start local 6 // io.netty.handler.codec.mqtt.MqttDecoder$Result keepAlive
         8: .line 222
            iload 2 /* numberOfBytesConsumed */
            aload 6 /* keepAlive */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 2 /* numberOfBytesConsumed */
         9: .line 224
            iload 5 /* b1 */
            sipush 128
            iand
            sipush 128
            if_icmpne 10
            iconst_1
            goto 11
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttDecoder$Result int int io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack:
        10: iconst_0
      StackMap locals:
      StackMap stack: int
        11: istore 7 /* hasUserName */
        start local 7 // boolean hasUserName
        12: .line 225
            iload 5 /* b1 */
            bipush 64
            iand
            bipush 64
            if_icmpne 13
            iconst_1
            goto 14
      StackMap locals: int
      StackMap stack:
        13: iconst_0
      StackMap locals:
      StackMap stack: int
        14: istore 8 /* hasPassword */
        start local 8 // boolean hasPassword
        15: .line 226
            iload 5 /* b1 */
            bipush 32
            iand
            bipush 32
            if_icmpne 16
            iconst_1
            goto 17
      StackMap locals: int
      StackMap stack:
        16: iconst_0
      StackMap locals:
      StackMap stack: int
        17: istore 9 /* willRetain */
        start local 9 // boolean willRetain
        18: .line 227
            iload 5 /* b1 */
            bipush 24
            iand
            iconst_3
            ishr
            istore 10 /* willQos */
        start local 10 // int willQos
        19: .line 228
            iload 5 /* b1 */
            iconst_4
            iand
            iconst_4
            if_icmpne 20
            iconst_1
            goto 21
      StackMap locals: int int
      StackMap stack:
        20: iconst_0
      StackMap locals:
      StackMap stack: int
        21: istore 11 /* willFlag */
        start local 11 // boolean willFlag
        22: .line 229
            iload 5 /* b1 */
            iconst_2
            iand
            iconst_2
            if_icmpne 23
            iconst_1
            goto 24
      StackMap locals: int
      StackMap stack:
        23: iconst_0
      StackMap locals:
      StackMap stack: int
        24: istore 12 /* cleanSession */
        start local 12 // boolean cleanSession
        25: .line 230
            aload 4 /* mqttVersion */
            getstatic io.netty.handler.codec.mqtt.MqttVersion.MQTT_3_1_1:Lio/netty/handler/codec/mqtt/MqttVersion;
            if_acmpne 31
        26: .line 231
            iload 5 /* b1 */
            iconst_1
            iand
            ifne 27
            iconst_1
            goto 28
      StackMap locals: int
      StackMap stack:
        27: iconst_0
      StackMap locals:
      StackMap stack: int
        28: istore 13 /* zeroReservedFlag */
        start local 13 // boolean zeroReservedFlag
        29: .line 232
            iload 13 /* zeroReservedFlag */
            ifne 31
        30: .line 236
            new io.netty.handler.codec.DecoderException
            dup
            ldc "non-zero reserved flag"
            invokespecial io.netty.handler.codec.DecoderException.<init>:(Ljava/lang/String;)V
            athrow
        end local 13 // boolean zeroReservedFlag
        31: .line 240
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttConnectVariableHeader
            dup
        32: .line 241
            aload 4 /* mqttVersion */
            invokevirtual io.netty.handler.codec.mqtt.MqttVersion.protocolName:()Ljava/lang/String;
        33: .line 242
            aload 4 /* mqttVersion */
            invokevirtual io.netty.handler.codec.mqtt.MqttVersion.protocolLevel:()B
        34: .line 243
            iload 7 /* hasUserName */
        35: .line 244
            iload 8 /* hasPassword */
        36: .line 245
            iload 9 /* willRetain */
        37: .line 246
            iload 10 /* willQos */
        38: .line 247
            iload 11 /* willFlag */
        39: .line 248
            iload 12 /* cleanSession */
        40: .line 249
            aload 6 /* keepAlive */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
        41: .line 240
            invokespecial io.netty.handler.codec.mqtt.MqttConnectVariableHeader.<init>:(Ljava/lang/String;IZZZIZZI)V
            astore 13 /* mqttConnectVariableHeader */
        start local 13 // io.netty.handler.codec.mqtt.MqttConnectVariableHeader mqttConnectVariableHeader
        42: .line 250
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aload 13 /* mqttConnectVariableHeader */
            iload 2 /* numberOfBytesConsumed */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 13 // io.netty.handler.codec.mqtt.MqttConnectVariableHeader mqttConnectVariableHeader
        end local 12 // boolean cleanSession
        end local 11 // boolean willFlag
        end local 10 // int willQos
        end local 9 // boolean willRetain
        end local 8 // boolean hasPassword
        end local 7 // boolean hasUserName
        end local 6 // io.netty.handler.codec.mqtt.MqttDecoder$Result keepAlive
        end local 5 // int b1
        end local 4 // io.netty.handler.codec.mqtt.MqttVersion mqttVersion
        end local 3 // byte protocolLevel
        end local 2 // int numberOfBytesConsumed
        end local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result protoString
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                       Name  Signature
            0   43     0                     buffer  Lio/netty/buffer/ByteBuf;
            1   43     1                protoString  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
            2   43     2      numberOfBytesConsumed  I
            3   43     3              protocolLevel  B
            5   43     4                mqttVersion  Lio/netty/handler/codec/mqtt/MqttVersion;
            6   43     5                         b1  I
            8   43     6                  keepAlive  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
           12   43     7                hasUserName  Z
           15   43     8                hasPassword  Z
           18   43     9                 willRetain  Z
           19   43    10                    willQos  I
           22   43    11                   willFlag  Z
           25   43    12               cleanSession  Z
           29   31    13           zeroReservedFlag  Z
           42   43    13  mqttConnectVariableHeader  Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
    Signature: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;>;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttConnAckVariableHeader> decodeConnAckVariableHeader(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 254
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            iconst_1
            iand
            iconst_1
            if_icmpne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: istore 1 /* sessionPresent */
        start local 1 // boolean sessionPresent
         3: .line 255
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readByte:()B
            istore 2 /* returnCode */
        start local 2 // byte returnCode
         4: .line 258
            new io.netty.handler.codec.mqtt.MqttConnAckVariableHeader
            dup
            iload 2 /* returnCode */
            invokestatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.valueOf:(B)Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            iload 1 /* sessionPresent */
            invokespecial io.netty.handler.codec.mqtt.MqttConnAckVariableHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;Z)V
         5: .line 257
            astore 3 /* mqttConnAckVariableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttConnAckVariableHeader mqttConnAckVariableHeader
         6: .line 259
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aload 3 /* mqttConnAckVariableHeader */
            iconst_2
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 3 // io.netty.handler.codec.mqtt.MqttConnAckVariableHeader mqttConnAckVariableHeader
        end local 2 // byte returnCode
        end local 1 // boolean sessionPresent
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                       Name  Signature
            0    7     0                     buffer  Lio/netty/buffer/ByteBuf;
            3    7     1             sessionPresent  Z
            4    7     2                 returnCode  B
            6    7     3  mqttConnAckVariableHeader  Lio/netty/handler/codec/mqtt/MqttConnAckVariableHeader;
    Signature: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttConnAckVariableHeader;>;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader> decodeMessageIdVariableHeader(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 263
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMessageId:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 1 /* messageId */
        start local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result messageId
         1: .line 264
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
         2: .line 265
            aload 1 /* messageId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 266
            aload 1 /* messageId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
         4: .line 264
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result messageId
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0     buffer  Lio/netty/buffer/ByteBuf;
            1    5     1  messageId  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
    Signature: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;>;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttPublishVariableHeader> decodePublishVariableHeader(io.netty.buffer.ByteBuf, io.netty.handler.codec.mqtt.MqttFixedHeader);
    descriptor: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=6, args_size=2
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // io.netty.handler.codec.mqtt.MqttFixedHeader mqttFixedHeader
         0: .line 272
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 2 /* decodedTopic */
        start local 2 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedTopic
         1: .line 273
            aload 2 /* decodedTopic */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            invokestatic io.netty.handler.codec.mqtt.MqttCodecUtil.isValidPublishTopicName:(Ljava/lang/String;)Z
            ifne 3
         2: .line 274
            new io.netty.handler.codec.DecoderException
            dup
            new java.lang.StringBuilder
            dup
            ldc "invalid publish topic name: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* decodedTopic */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " (contains wildcards)"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial io.netty.handler.codec.DecoderException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 276
      StackMap locals: io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack:
            aload 2 /* decodedTopic */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            istore 3 /* numberOfBytesConsumed */
        start local 3 // int numberOfBytesConsumed
         4: .line 278
            iconst_m1
            istore 4 /* messageId */
        start local 4 // int messageId
         5: .line 279
            aload 1 /* mqttFixedHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
            invokevirtual io.netty.handler.codec.mqtt.MqttQoS.value:()I
            ifle 9
         6: .line 280
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMessageId:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 5 /* decodedMessageId */
        start local 5 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedMessageId
         7: .line 281
            aload 5 /* decodedMessageId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            istore 4 /* messageId */
         8: .line 282
            iload 3 /* numberOfBytesConsumed */
            aload 5 /* decodedMessageId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 3 /* numberOfBytesConsumed */
        end local 5 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedMessageId
         9: .line 285
      StackMap locals: int int
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttPublishVariableHeader
            dup
            aload 2 /* decodedTopic */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            iload 4 /* messageId */
            invokespecial io.netty.handler.codec.mqtt.MqttPublishVariableHeader.<init>:(Ljava/lang/String;I)V
        10: .line 284
            astore 5 /* mqttPublishVariableHeader */
        start local 5 // io.netty.handler.codec.mqtt.MqttPublishVariableHeader mqttPublishVariableHeader
        11: .line 286
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aload 5 /* mqttPublishVariableHeader */
            iload 3 /* numberOfBytesConsumed */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 5 // io.netty.handler.codec.mqtt.MqttPublishVariableHeader mqttPublishVariableHeader
        end local 4 // int messageId
        end local 3 // int numberOfBytesConsumed
        end local 2 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedTopic
        end local 1 // io.netty.handler.codec.mqtt.MqttFixedHeader mqttFixedHeader
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                       Name  Signature
            0   12     0                     buffer  Lio/netty/buffer/ByteBuf;
            0   12     1            mqttFixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            1   12     2               decodedTopic  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
            4   12     3      numberOfBytesConsumed  I
            5   12     4                  messageId  I
            7    9     5           decodedMessageId  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
           11   12     5  mqttPublishVariableHeader  Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
    Signature: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttFixedHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;>;
    MethodParameters:
                 Name  Flags
      buffer           
      mqttFixedHeader  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<java.lang.Integer> decodeMessageId(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=2, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 290
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 1 /* messageId */
        start local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result messageId
         1: .line 291
            aload 1 /* messageId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            invokestatic io.netty.handler.codec.mqtt.MqttCodecUtil.isValidMessageId:(I)Z
            ifne 3
         2: .line 292
            new io.netty.handler.codec.DecoderException
            dup
            new java.lang.StringBuilder
            dup
            ldc "invalid messageId: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* messageId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial io.netty.handler.codec.DecoderException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 294
      StackMap locals: io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack:
            aload 1 /* messageId */
            areturn
        end local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result messageId
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0     buffer  Lio/netty/buffer/ByteBuf;
            1    4     1  messageId  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
    Signature: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<?> decodePayload(io.netty.buffer.ByteBuf, io.netty.handler.codec.mqtt.MqttMessageType, int, );
    descriptor: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttMessageType;ILjava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // io.netty.handler.codec.mqtt.MqttMessageType messageType
        start local 2 // int bytesRemainingInVariablePart
        start local 3 // java.lang.Object variableHeader
         0: .line 311
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:()[I
            aload 1 /* messageType */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
            iaload
            tableswitch { // 1 - 10
                    1: 1
                    2: 6
                    3: 5
                    4: 6
                    5: 6
                    6: 6
                    7: 6
                    8: 2
                    9: 3
                   10: 4
              default: 6
          }
         1: .line 313
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            aload 3 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttConnectVariableHeader
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeConnectionPayload:(Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         2: .line 316
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            iload 2 /* bytesRemainingInVariablePart */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeSubscribePayload:(Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         3: .line 319
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            iload 2 /* bytesRemainingInVariablePart */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeSubackPayload:(Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         4: .line 322
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            iload 2 /* bytesRemainingInVariablePart */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeUnsubscribePayload:(Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         5: .line 325
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            iload 2 /* bytesRemainingInVariablePart */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodePublishPayload:(Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
         6: .line 329
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aconst_null
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 3 // java.lang.Object variableHeader
        end local 2 // int bytesRemainingInVariablePart
        end local 1 // io.netty.handler.codec.mqtt.MqttMessageType messageType
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                          Name  Signature
            0    7     0                        buffer  Lio/netty/buffer/ByteBuf;
            0    7     1                   messageType  Lio/netty/handler/codec/mqtt/MqttMessageType;
            0    7     2  bytesRemainingInVariablePart  I
            0    7     3                variableHeader  Ljava/lang/Object;
    Signature: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttMessageType;ILjava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<*>;
    MethodParameters:
                              Name  Flags
      buffer                        
      messageType                   
      bytesRemainingInVariablePart  
      variableHeader                

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttConnectPayload> decodeConnectionPayload(io.netty.buffer.ByteBuf, io.netty.handler.codec.mqtt.MqttConnectVariableHeader);
    descriptor: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=7, locals=11, args_size=2
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // io.netty.handler.codec.mqtt.MqttConnectVariableHeader mqttConnectVariableHeader
         0: .line 336
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 2 /* decodedClientId */
        start local 2 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedClientId
         1: .line 337
            aload 2 /* decodedClientId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            astore 3 /* decodedClientIdValue */
        start local 3 // java.lang.String decodedClientIdValue
         2: .line 338
            aload 1 /* mqttConnectVariableHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.name:()Ljava/lang/String;
         3: .line 339
            aload 1 /* mqttConnectVariableHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.version:()I
            i2b
         4: .line 338
            invokestatic io.netty.handler.codec.mqtt.MqttVersion.fromProtocolNameAndLevel:(Ljava/lang/String;B)Lio/netty/handler/codec/mqtt/MqttVersion;
            astore 4 /* mqttVersion */
        start local 4 // io.netty.handler.codec.mqtt.MqttVersion mqttVersion
         5: .line 340
            aload 4 /* mqttVersion */
            aload 3 /* decodedClientIdValue */
            invokestatic io.netty.handler.codec.mqtt.MqttCodecUtil.isValidClientId:(Lio/netty/handler/codec/mqtt/MqttVersion;Ljava/lang/String;)Z
            ifne 7
         6: .line 341
            new io.netty.handler.codec.mqtt.MqttIdentifierRejectedException
            dup
            new java.lang.StringBuilder
            dup
            ldc "invalid clientIdentifier: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 3 /* decodedClientIdValue */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial io.netty.handler.codec.mqtt.MqttIdentifierRejectedException.<init>:(Ljava/lang/String;)V
            athrow
         7: .line 343
      StackMap locals: io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion
      StackMap stack:
            aload 2 /* decodedClientId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            istore 5 /* numberOfBytesConsumed */
        start local 5 // int numberOfBytesConsumed
         8: .line 345
            aconst_null
            astore 6 /* decodedWillTopic */
        start local 6 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedWillTopic
         9: .line 346
            aconst_null
            astore 7 /* decodedWillMessage */
        start local 7 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedWillMessage
        10: .line 347
            aload 1 /* mqttConnectVariableHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.isWillFlag:()Z
            ifeq 15
        11: .line 348
            aload 0 /* buffer */
            iconst_0
            sipush 32767
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;II)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 6 /* decodedWillTopic */
        12: .line 349
            iload 5 /* numberOfBytesConsumed */
            aload 6 /* decodedWillTopic */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 5 /* numberOfBytesConsumed */
        13: .line 350
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeByteArray:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 7 /* decodedWillMessage */
        14: .line 351
            iload 5 /* numberOfBytesConsumed */
            aload 7 /* decodedWillMessage */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 5 /* numberOfBytesConsumed */
        15: .line 353
      StackMap locals: int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack:
            aconst_null
            astore 8 /* decodedUserName */
        start local 8 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedUserName
        16: .line 354
            aconst_null
            astore 9 /* decodedPassword */
        start local 9 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedPassword
        17: .line 355
            aload 1 /* mqttConnectVariableHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.hasUserName:()Z
            ifeq 20
        18: .line 356
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 8 /* decodedUserName */
        19: .line 357
            iload 5 /* numberOfBytesConsumed */
            aload 8 /* decodedUserName */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 5 /* numberOfBytesConsumed */
        20: .line 359
      StackMap locals: io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack:
            aload 1 /* mqttConnectVariableHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttConnectVariableHeader.hasPassword:()Z
            ifeq 23
        21: .line 360
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeByteArray:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 9 /* decodedPassword */
        22: .line 361
            iload 5 /* numberOfBytesConsumed */
            aload 9 /* decodedPassword */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 5 /* numberOfBytesConsumed */
        23: .line 365
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttConnectPayload
            dup
        24: .line 366
            aload 2 /* decodedClientId */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
        25: .line 367
            aload 6 /* decodedWillTopic */
            ifnull 26
            aload 6 /* decodedWillTopic */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            goto 27
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String
        26: aconst_null
        27: .line 368
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String java.lang.String
            aload 7 /* decodedWillMessage */
            ifnull 28
            aload 7 /* decodedWillMessage */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast byte[]
            goto 29
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String java.lang.String
        28: aconst_null
        29: .line 369
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String java.lang.String byte[]
            aload 8 /* decodedUserName */
            ifnull 30
            aload 8 /* decodedUserName */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            goto 31
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String java.lang.String byte[]
        30: aconst_null
        31: .line 370
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String java.lang.String byte[] java.lang.String
            aload 9 /* decodedPassword */
            ifnull 32
            aload 9 /* decodedPassword */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast byte[]
            goto 33
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String java.lang.String byte[] java.lang.String
        32: aconst_null
        33: .line 365
      StackMap locals: io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttConnectVariableHeader io.netty.handler.codec.mqtt.MqttDecoder$Result java.lang.String io.netty.handler.codec.mqtt.MqttVersion int io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result io.netty.handler.codec.mqtt.MqttDecoder$Result
      StackMap stack: new 23 new 23 java.lang.String java.lang.String byte[] java.lang.String byte[]
            invokespecial io.netty.handler.codec.mqtt.MqttConnectPayload.<init>:(Ljava/lang/String;Ljava/lang/String;[BLjava/lang/String;[B)V
        34: .line 364
            astore 10 /* mqttConnectPayload */
        start local 10 // io.netty.handler.codec.mqtt.MqttConnectPayload mqttConnectPayload
        35: .line 371
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aload 10 /* mqttConnectPayload */
            iload 5 /* numberOfBytesConsumed */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 10 // io.netty.handler.codec.mqtt.MqttConnectPayload mqttConnectPayload
        end local 9 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedPassword
        end local 8 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedUserName
        end local 7 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedWillMessage
        end local 6 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedWillTopic
        end local 5 // int numberOfBytesConsumed
        end local 4 // io.netty.handler.codec.mqtt.MqttVersion mqttVersion
        end local 3 // java.lang.String decodedClientIdValue
        end local 2 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedClientId
        end local 1 // io.netty.handler.codec.mqtt.MqttConnectVariableHeader mqttConnectVariableHeader
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                       Name  Signature
            0   36     0                     buffer  Lio/netty/buffer/ByteBuf;
            0   36     1  mqttConnectVariableHeader  Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
            1   36     2            decodedClientId  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
            2   36     3       decodedClientIdValue  Ljava/lang/String;
            5   36     4                mqttVersion  Lio/netty/handler/codec/mqtt/MqttVersion;
            8   36     5      numberOfBytesConsumed  I
            9   36     6           decodedWillTopic  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
           10   36     7         decodedWillMessage  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<[B>;
           16   36     8            decodedUserName  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
           17   36     9            decodedPassword  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<[B>;
           35   36    10         mqttConnectPayload  Lio/netty/handler/codec/mqtt/MqttConnectPayload;
    Signature: (Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttConnectPayload;>;
    MethodParameters:
                           Name  Flags
      buffer                     
      mqttConnectVariableHeader  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttSubscribePayload> decodeSubscribePayload(io.netty.buffer.ByteBuf, int);
    descriptor: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=6, args_size=2
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // int bytesRemainingInVariablePart
         0: .line 377
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* subscribeTopics */
        start local 2 // java.util.List subscribeTopics
         1: .line 378
            iconst_0
            istore 3 /* numberOfBytesConsumed */
        start local 3 // int numberOfBytesConsumed
         2: .line 379
            goto 8
         3: .line 380
      StackMap locals: java.util.List int
      StackMap stack:
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 4 /* decodedTopicName */
        start local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedTopicName
         4: .line 381
            iload 3 /* numberOfBytesConsumed */
            aload 4 /* decodedTopicName */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 3 /* numberOfBytesConsumed */
         5: .line 382
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            iconst_3
            iand
            istore 5 /* qos */
        start local 5 // int qos
         6: .line 383
            iinc 3 /* numberOfBytesConsumed */ 1
         7: .line 384
            aload 2 /* subscribeTopics */
            new io.netty.handler.codec.mqtt.MqttTopicSubscription
            dup
            aload 4 /* decodedTopicName */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            iload 5 /* qos */
            invokestatic io.netty.handler.codec.mqtt.MqttQoS.valueOf:(I)Lio/netty/handler/codec/mqtt/MqttQoS;
            invokespecial io.netty.handler.codec.mqtt.MqttTopicSubscription.<init>:(Ljava/lang/String;Lio/netty/handler/codec/mqtt/MqttQoS;)V
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 5 // int qos
        end local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedTopicName
         8: .line 379
      StackMap locals:
      StackMap stack:
            iload 3 /* numberOfBytesConsumed */
            iload 1 /* bytesRemainingInVariablePart */
            if_icmplt 3
         9: .line 386
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            new io.netty.handler.codec.mqtt.MqttSubscribePayload
            dup
            aload 2 /* subscribeTopics */
            invokespecial io.netty.handler.codec.mqtt.MqttSubscribePayload.<init>:(Ljava/util/List;)V
            iload 3 /* numberOfBytesConsumed */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 3 // int numberOfBytesConsumed
        end local 2 // java.util.List subscribeTopics
        end local 1 // int bytesRemainingInVariablePart
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                          Name  Signature
            0   10     0                        buffer  Lio/netty/buffer/ByteBuf;
            0   10     1  bytesRemainingInVariablePart  I
            1   10     2               subscribeTopics  Ljava/util/List<Lio/netty/handler/codec/mqtt/MqttTopicSubscription;>;
            2   10     3         numberOfBytesConsumed  I
            4    8     4              decodedTopicName  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
            6    8     5                           qos  I
    Signature: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttSubscribePayload;>;
    MethodParameters:
                              Name  Flags
      buffer                        
      bytesRemainingInVariablePart  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttSubAckPayload> decodeSubackPayload(io.netty.buffer.ByteBuf, int);
    descriptor: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // int bytesRemainingInVariablePart
         0: .line 392
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* grantedQos */
        start local 2 // java.util.List grantedQos
         1: .line 393
            iconst_0
            istore 3 /* numberOfBytesConsumed */
        start local 3 // int numberOfBytesConsumed
         2: .line 394
            goto 8
         3: .line 395
      StackMap locals: java.util.List int
      StackMap stack:
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            istore 4 /* qos */
        start local 4 // int qos
         4: .line 396
            iload 4 /* qos */
            getstatic io.netty.handler.codec.mqtt.MqttQoS.FAILURE:Lio/netty/handler/codec/mqtt/MqttQoS;
            invokevirtual io.netty.handler.codec.mqtt.MqttQoS.value:()I
            if_icmpeq 6
         5: .line 397
            iload 4 /* qos */
            iconst_3
            iand
            istore 4 /* qos */
         6: .line 399
      StackMap locals: int
      StackMap stack:
            iinc 3 /* numberOfBytesConsumed */ 1
         7: .line 400
            aload 2 /* grantedQos */
            iload 4 /* qos */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 4 // int qos
         8: .line 394
      StackMap locals:
      StackMap stack:
            iload 3 /* numberOfBytesConsumed */
            iload 1 /* bytesRemainingInVariablePart */
            if_icmplt 3
         9: .line 402
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            new io.netty.handler.codec.mqtt.MqttSubAckPayload
            dup
            aload 2 /* grantedQos */
            invokespecial io.netty.handler.codec.mqtt.MqttSubAckPayload.<init>:(Ljava/lang/Iterable;)V
            iload 3 /* numberOfBytesConsumed */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 3 // int numberOfBytesConsumed
        end local 2 // java.util.List grantedQos
        end local 1 // int bytesRemainingInVariablePart
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                          Name  Signature
            0   10     0                        buffer  Lio/netty/buffer/ByteBuf;
            0   10     1  bytesRemainingInVariablePart  I
            1   10     2                    grantedQos  Ljava/util/List<Ljava/lang/Integer;>;
            2   10     3         numberOfBytesConsumed  I
            4    8     4                           qos  I
    Signature: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttSubAckPayload;>;
    MethodParameters:
                              Name  Flags
      buffer                        
      bytesRemainingInVariablePart  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.handler.codec.mqtt.MqttUnsubscribePayload> decodeUnsubscribePayload(io.netty.buffer.ByteBuf, int);
    descriptor: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // int bytesRemainingInVariablePart
         0: .line 408
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* unsubscribeTopics */
        start local 2 // java.util.List unsubscribeTopics
         1: .line 409
            iconst_0
            istore 3 /* numberOfBytesConsumed */
        start local 3 // int numberOfBytesConsumed
         2: .line 410
            goto 6
         3: .line 411
      StackMap locals: java.util.List int
      StackMap stack:
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 4 /* decodedTopicName */
        start local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedTopicName
         4: .line 412
            iload 3 /* numberOfBytesConsumed */
            aload 4 /* decodedTopicName */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iadd
            istore 3 /* numberOfBytesConsumed */
         5: .line 413
            aload 2 /* unsubscribeTopics */
            aload 4 /* decodedTopicName */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.String
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 4 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedTopicName
         6: .line 410
      StackMap locals:
      StackMap stack:
            iload 3 /* numberOfBytesConsumed */
            iload 1 /* bytesRemainingInVariablePart */
            if_icmplt 3
         7: .line 415
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
         8: .line 416
            new io.netty.handler.codec.mqtt.MqttUnsubscribePayload
            dup
            aload 2 /* unsubscribeTopics */
            invokespecial io.netty.handler.codec.mqtt.MqttUnsubscribePayload.<init>:(Ljava/util/List;)V
         9: .line 417
            iload 3 /* numberOfBytesConsumed */
        10: .line 415
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 3 // int numberOfBytesConsumed
        end local 2 // java.util.List unsubscribeTopics
        end local 1 // int bytesRemainingInVariablePart
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                          Name  Signature
            0   11     0                        buffer  Lio/netty/buffer/ByteBuf;
            0   11     1  bytesRemainingInVariablePart  I
            1   11     2             unsubscribeTopics  Ljava/util/List<Ljava/lang/String;>;
            2   11     3         numberOfBytesConsumed  I
            4    6     4              decodedTopicName  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
    Signature: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/handler/codec/mqtt/MqttUnsubscribePayload;>;
    MethodParameters:
                              Name  Flags
      buffer                        
      bytesRemainingInVariablePart  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<io.netty.buffer.ByteBuf> decodePublishPayload(io.netty.buffer.ByteBuf, int);
    descriptor: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // int bytesRemainingInVariablePart
         0: .line 421
            aload 0 /* buffer */
            iload 1 /* bytesRemainingInVariablePart */
            invokevirtual io.netty.buffer.ByteBuf.readRetainedSlice:(I)Lio/netty/buffer/ByteBuf;
            astore 2 /* b */
        start local 2 // io.netty.buffer.ByteBuf b
         1: .line 422
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aload 2 /* b */
            iload 1 /* bytesRemainingInVariablePart */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 2 // io.netty.buffer.ByteBuf b
        end local 1 // int bytesRemainingInVariablePart
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                          Name  Signature
            0    2     0                        buffer  Lio/netty/buffer/ByteBuf;
            0    2     1  bytesRemainingInVariablePart  I
            1    2     2                             b  Lio/netty/buffer/ByteBuf;
    Signature: (Lio/netty/buffer/ByteBuf;I)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Lio/netty/buffer/ByteBuf;>;
    MethodParameters:
                              Name  Flags
      buffer                        
      bytesRemainingInVariablePart  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<java.lang.String> decodeString(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 426
            aload 0 /* buffer */
            iconst_0
            ldc 2147483647
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeString:(Lio/netty/buffer/ByteBuf;II)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  buffer  Lio/netty/buffer/ByteBuf;
    Signature: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<java.lang.String> decodeString(io.netty.buffer.ByteBuf, int, int);
    descriptor: (Lio/netty/buffer/ByteBuf;II)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=7, args_size=3
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // int minBytes
        start local 2 // int maxBytes
         0: .line 430
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 3 /* decodedSize */
        start local 3 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedSize
         1: .line 431
            aload 3 /* decodedSize */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            istore 4 /* size */
        start local 4 // int size
         2: .line 432
            aload 3 /* decodedSize */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            istore 5 /* numberOfBytesConsumed */
        start local 5 // int numberOfBytesConsumed
         3: .line 433
            iload 4 /* size */
            iload 1 /* minBytes */
            if_icmplt 4
            iload 4 /* size */
            iload 2 /* maxBytes */
            if_icmple 7
         4: .line 434
      StackMap locals: io.netty.handler.codec.mqtt.MqttDecoder$Result int int
      StackMap stack:
            aload 0 /* buffer */
            iload 4 /* size */
            invokevirtual io.netty.buffer.ByteBuf.skipBytes:(I)Lio/netty/buffer/ByteBuf;
            pop
         5: .line 435
            iload 5 /* numberOfBytesConsumed */
            iload 4 /* size */
            iadd
            istore 5 /* numberOfBytesConsumed */
         6: .line 436
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aconst_null
            iload 5 /* numberOfBytesConsumed */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
         7: .line 438
      StackMap locals:
      StackMap stack:
            aload 0 /* buffer */
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readerIndex:()I
            iload 4 /* size */
            getstatic io.netty.util.CharsetUtil.UTF_8:Ljava/nio/charset/Charset;
            invokevirtual io.netty.buffer.ByteBuf.toString:(IILjava/nio/charset/Charset;)Ljava/lang/String;
            astore 6 /* s */
        start local 6 // java.lang.String s
         8: .line 439
            aload 0 /* buffer */
            iload 4 /* size */
            invokevirtual io.netty.buffer.ByteBuf.skipBytes:(I)Lio/netty/buffer/ByteBuf;
            pop
         9: .line 440
            iload 5 /* numberOfBytesConsumed */
            iload 4 /* size */
            iadd
            istore 5 /* numberOfBytesConsumed */
        10: .line 441
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aload 6 /* s */
            iload 5 /* numberOfBytesConsumed */
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 6 // java.lang.String s
        end local 5 // int numberOfBytesConsumed
        end local 4 // int size
        end local 3 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedSize
        end local 2 // int maxBytes
        end local 1 // int minBytes
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0   11     0                 buffer  Lio/netty/buffer/ByteBuf;
            0   11     1               minBytes  I
            0   11     2               maxBytes  I
            1   11     3            decodedSize  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
            2   11     4                   size  I
            3   11     5  numberOfBytesConsumed  I
            8   11     6                      s  Ljava/lang/String;
    Signature: (Lio/netty/buffer/ByteBuf;II)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/String;>;
    MethodParameters:
          Name  Flags
      buffer    
      minBytes  
      maxBytes  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<byte[]> decodeByteArray(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=4, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 445
            aload 0 /* buffer */
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb:(Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            astore 1 /* decodedSize */
        start local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedSize
         1: .line 446
            aload 1 /* decodedSize */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.value:Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            istore 2 /* size */
        start local 2 // int size
         2: .line 447
            iload 2 /* size */
            newarray 8
            astore 3 /* bytes */
        start local 3 // byte[] bytes
         3: .line 448
            aload 0 /* buffer */
            aload 3 /* bytes */
            invokevirtual io.netty.buffer.ByteBuf.readBytes:([B)Lio/netty/buffer/ByteBuf;
            pop
         4: .line 449
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            aload 3 /* bytes */
            aload 1 /* decodedSize */
            getfield io.netty.handler.codec.mqtt.MqttDecoder$Result.numberOfBytesConsumed:I
            iload 2 /* size */
            iadd
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 3 // byte[] bytes
        end local 2 // int size
        end local 1 // io.netty.handler.codec.mqtt.MqttDecoder$Result decodedSize
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    5     0       buffer  Lio/netty/buffer/ByteBuf;
            1    5     1  decodedSize  Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
            2    5     2         size  I
            3    5     3        bytes  [B
    Signature: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<[B>;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<java.lang.Integer> decodeMsbLsb(io.netty.buffer.ByteBuf);
    descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.netty.buffer.ByteBuf buffer
         0: .line 453
            aload 0 /* buffer */
            iconst_0
            ldc 65535
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder.decodeMsbLsb:(Lio/netty/buffer/ByteBuf;II)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
            areturn
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  buffer  Lio/netty/buffer/ByteBuf;
    Signature: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
    MethodParameters:
        Name  Flags
      buffer  

  private static io.netty.handler.codec.mqtt.MqttDecoder$Result<java.lang.Integer> decodeMsbLsb(io.netty.buffer.ByteBuf, int, int);
    descriptor: (Lio/netty/buffer/ByteBuf;II)Lio/netty/handler/codec/mqtt/MqttDecoder$Result;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=6, args_size=3
        start local 0 // io.netty.buffer.ByteBuf buffer
        start local 1 // int min
        start local 2 // int max
         0: .line 457
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            istore 3 /* msbSize */
        start local 3 // short msbSize
         1: .line 458
            aload 0 /* buffer */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedByte:()S
            istore 4 /* lsbSize */
        start local 4 // short lsbSize
         2: .line 460
            iload 3 /* msbSize */
            bipush 8
            ishl
            iload 4 /* lsbSize */
            ior
            istore 5 /* result */
        start local 5 // int result
         3: .line 461
            iload 5 /* result */
            iload 1 /* min */
            if_icmplt 4
            iload 5 /* result */
            iload 2 /* max */
            if_icmple 5
         4: .line 462
      StackMap locals: int int int
      StackMap stack:
            iconst_m1
            istore 5 /* result */
         5: .line 464
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttDecoder$Result
            dup
            iload 5 /* result */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            iconst_2
            invokespecial io.netty.handler.codec.mqtt.MqttDecoder$Result.<init>:(Ljava/lang/Object;I)V
            areturn
        end local 5 // int result
        end local 4 // short lsbSize
        end local 3 // short msbSize
        end local 2 // int max
        end local 1 // int min
        end local 0 // io.netty.buffer.ByteBuf buffer
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0   buffer  Lio/netty/buffer/ByteBuf;
            0    6     1      min  I
            0    6     2      max  I
            1    6     3  msbSize  S
            2    6     4  lsbSize  S
            3    6     5   result  I
    Signature: (Lio/netty/buffer/ByteBuf;II)Lio/netty/handler/codec/mqtt/MqttDecoder$Result<Ljava/lang/Integer;>;
    MethodParameters:
        Name  Flags
      buffer  
      min     
      max     

  static int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttDecoder$DecoderState();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 40
            getstatic io.netty.handler.codec.mqtt.MqttDecoder.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttDecoder$DecoderState:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.values:()[Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.BAD_MESSAGE:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.ordinal:()I
            iconst_4
            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.MqttDecoder$DecoderState.READ_FIXED_HEADER:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.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.MqttDecoder$DecoderState.READ_PAYLOAD:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.ordinal:()I
            iconst_3
            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.MqttDecoder$DecoderState.READ_VARIABLE_HEADER:Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;
            invokevirtual io.netty.handler.codec.mqtt.MqttDecoder$DecoderState.ordinal:()I
            iconst_2
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            dup
            putstatic io.netty.handler.codec.mqtt.MqttDecoder.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttDecoder$DecoderState:[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

  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 40
            getstatic io.netty.handler.codec.mqtt.MqttDecoder.$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.netty.handler.codec.mqtt.MqttDecoder.$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
}
Signature: Lio/netty/handler/codec/ReplayingDecoder<Lio/netty/handler/codec/mqtt/MqttDecoder$DecoderState;>;
SourceFile: "MqttDecoder.java"
NestMembers:
  io.netty.handler.codec.mqtt.MqttDecoder$DecoderState  io.netty.handler.codec.mqtt.MqttDecoder$Result
InnerClasses:
  final DecoderState = io.netty.handler.codec.mqtt.MqttDecoder$DecoderState of io.netty.handler.codec.mqtt.MqttDecoder
  private final Result = io.netty.handler.codec.mqtt.MqttDecoder$Result of io.netty.handler.codec.mqtt.MqttDecoder
/

io.netty/ netty-all/ 4.1.25.Final/ io/netty/handler/codec/mqtt/MqttDecoder.class
