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

MqttMessageFactory
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.MqttMessageFactory
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: io.netty.handler.codec.mqtt.MqttMessageFactory
  super_class: java.lang.Object
{
  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 static io.netty.handler.codec.mqtt.MqttMessage newMessage(io.netty.handler.codec.mqtt.MqttFixedHeader, java.lang.Object, java.lang.Object);
    descriptor: (Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.netty.handler.codec.mqtt.MqttFixedHeader mqttFixedHeader
        start local 1 // java.lang.Object variableHeader
        start local 2 // java.lang.Object payload
         0: .line 28
            invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:()[I
            aload 0 /* 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: 6
                    3: 26
                    4: 31
                    5: 32
                    6: 32
                    7: 32
                    8: 7
                    9: 12
                   10: 21
                   11: 17
                   12: 33
                   13: 33
                   14: 33
              default: 34
          }
         1: .line 30
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttConnectMessage
            dup
         2: .line 31
            aload 0 /* mqttFixedHeader */
         3: .line 32
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttConnectVariableHeader
         4: .line 33
            aload 2 /* payload */
            checkcast io.netty.handler.codec.mqtt.MqttConnectPayload
         5: .line 30
            invokespecial io.netty.handler.codec.mqtt.MqttConnectMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;Lio/netty/handler/codec/mqtt/MqttConnectPayload;)V
            areturn
         6: .line 36
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttConnAckMessage
            dup
            aload 0 /* mqttFixedHeader */
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttConnAckVariableHeader
            invokespecial io.netty.handler.codec.mqtt.MqttConnAckMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttConnAckVariableHeader;)V
            areturn
         7: .line 39
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttSubscribeMessage
            dup
         8: .line 40
            aload 0 /* mqttFixedHeader */
         9: .line 41
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
        10: .line 42
            aload 2 /* payload */
            checkcast io.netty.handler.codec.mqtt.MqttSubscribePayload
        11: .line 39
            invokespecial io.netty.handler.codec.mqtt.MqttSubscribeMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;Lio/netty/handler/codec/mqtt/MqttSubscribePayload;)V
            areturn
        12: .line 45
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttSubAckMessage
            dup
        13: .line 46
            aload 0 /* mqttFixedHeader */
        14: .line 47
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
        15: .line 48
            aload 2 /* payload */
            checkcast io.netty.handler.codec.mqtt.MqttSubAckPayload
        16: .line 45
            invokespecial io.netty.handler.codec.mqtt.MqttSubAckMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;Lio/netty/handler/codec/mqtt/MqttSubAckPayload;)V
            areturn
        17: .line 51
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttUnsubAckMessage
            dup
        18: .line 52
            aload 0 /* mqttFixedHeader */
        19: .line 53
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
        20: .line 51
            invokespecial io.netty.handler.codec.mqtt.MqttUnsubAckMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;)V
            areturn
        21: .line 56
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttUnsubscribeMessage
            dup
        22: .line 57
            aload 0 /* mqttFixedHeader */
        23: .line 58
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
        24: .line 59
            aload 2 /* payload */
            checkcast io.netty.handler.codec.mqtt.MqttUnsubscribePayload
        25: .line 56
            invokespecial io.netty.handler.codec.mqtt.MqttUnsubscribeMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;Lio/netty/handler/codec/mqtt/MqttUnsubscribePayload;)V
            areturn
        26: .line 62
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttPublishMessage
            dup
        27: .line 63
            aload 0 /* mqttFixedHeader */
        28: .line 64
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttPublishVariableHeader
        29: .line 65
            aload 2 /* payload */
            checkcast io.netty.buffer.ByteBuf
        30: .line 62
            invokespecial io.netty.handler.codec.mqtt.MqttPublishMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;Lio/netty/buffer/ByteBuf;)V
            areturn
        31: .line 68
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttPubAckMessage
            dup
            aload 0 /* mqttFixedHeader */
            aload 1 /* variableHeader */
            checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
            invokespecial io.netty.handler.codec.mqtt.MqttPubAckMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;)V
            areturn
        32: .line 72
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttMessage
            dup
            aload 0 /* mqttFixedHeader */
            aload 1 /* variableHeader */
            invokespecial io.netty.handler.codec.mqtt.MqttMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;)V
            areturn
        33: .line 77
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttMessage
            dup
            aload 0 /* mqttFixedHeader */
            invokespecial io.netty.handler.codec.mqtt.MqttMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;)V
            areturn
        34: .line 80
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "unknown message type: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* mqttFixedHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.messageType:()Lio/netty/handler/codec/mqtt/MqttMessageType;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
        end local 2 // java.lang.Object payload
        end local 1 // java.lang.Object variableHeader
        end local 0 // io.netty.handler.codec.mqtt.MqttFixedHeader mqttFixedHeader
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   35     0  mqttFixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            0   35     1   variableHeader  Ljava/lang/Object;
            0   35     2          payload  Ljava/lang/Object;
    MethodParameters:
                 Name  Flags
      mqttFixedHeader  
      variableHeader   
      payload          

  public static io.netty.handler.codec.mqtt.MqttMessage newInvalidMessage(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)Lio/netty/handler/codec/mqtt/MqttMessage;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 85
            new io.netty.handler.codec.mqtt.MqttMessage
            dup
            aconst_null
            aconst_null
            aconst_null
            aload 0 /* cause */
            invokestatic io.netty.handler.codec.DecoderResult.failure:(Ljava/lang/Throwable;)Lio/netty/handler/codec/DecoderResult;
            invokespecial io.netty.handler.codec.mqtt.MqttMessage.<init>:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;Lio/netty/handler/codec/DecoderResult;)V
            areturn
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;
    MethodParameters:
       Name  Flags
      cause  

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.netty.handler.codec.mqtt.MqttMessageFactory this
         0: .line 88
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // io.netty.handler.codec.mqtt.MqttMessageFactory this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/netty/handler/codec/mqtt/MqttMessageFactory;

  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 25
            getstatic io.netty.handler.codec.mqtt.MqttMessageFactory.$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.MqttMessageFactory.$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
}
SourceFile: "MqttMessageFactory.java"
/

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