public class io.vertx.mqtt.impl.MqttEndpointImpl implements io.vertx.mqtt.MqttEndpoint
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.mqtt.impl.MqttEndpointImpl
  super_class: java.lang.Object
{
  private static final int MAX_MESSAGE_ID;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 65535

  private static final io.vertx.core.impl.logging.Logger log;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

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

  private java.lang.String clientIdentifier;
    descriptor: Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE

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

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

  private final boolean isCleanSession;
    descriptor: Z
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  private final java.lang.String protocolName;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

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

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

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

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

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

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

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

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

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

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

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

  private boolean isConnected;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean isClosed;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

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

  private boolean isSubscriptionAutoAck;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean isPublishAutoAck;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean isAutoKeepAlive;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

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

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

  public void <init>(io.vertx.core.net.impl.NetSocketInternal, java.lang.String, io.vertx.mqtt.MqttAuth, io.vertx.mqtt.MqttWill, boolean, int, java.lang.String, int);
    descriptor: (Lio/vertx/core/net/impl/NetSocketInternal;Ljava/lang/String;Lio/vertx/mqtt/MqttAuth;Lio/vertx/mqtt/MqttWill;ZILjava/lang/String;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=9, args_size=9
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.net.impl.NetSocketInternal conn
        start local 2 // java.lang.String clientIdentifier
        start local 3 // io.vertx.mqtt.MqttAuth auth
        start local 4 // io.vertx.mqtt.MqttWill will
        start local 5 // boolean isCleanSession
        start local 6 // int protocolVersion
        start local 7 // java.lang.String protocolName
        start local 8 // int keepAliveTimeoutSeconds
         0: .line 115
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 101
            aload 0 /* this */
            iconst_1
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isAutoKeepAlive:Z
         2: .line 116
            aload 0 /* this */
            aload 1 /* conn */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
         3: .line 117
            aload 0 /* this */
            aload 2 /* clientIdentifier */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.clientIdentifier:Ljava/lang/String;
         4: .line 118
            aload 0 /* this */
            aload 3 /* auth */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.auth:Lio/vertx/mqtt/MqttAuth;
         5: .line 119
            aload 0 /* this */
            aload 4 /* will */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.will:Lio/vertx/mqtt/MqttWill;
         6: .line 120
            aload 0 /* this */
            iload 5 /* isCleanSession */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isCleanSession:Z
         7: .line 121
            aload 0 /* this */
            iload 6 /* protocolVersion */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.protocolVersion:I
         8: .line 122
            aload 0 /* this */
            aload 7 /* protocolName */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.protocolName:Ljava/lang/String;
         9: .line 123
            aload 0 /* this */
            iload 8 /* keepAliveTimeoutSeconds */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.keepAliveTimeoutSeconds:I
        10: .line 124
            return
        end local 8 // int keepAliveTimeoutSeconds
        end local 7 // java.lang.String protocolName
        end local 6 // int protocolVersion
        end local 5 // boolean isCleanSession
        end local 4 // io.vertx.mqtt.MqttWill will
        end local 3 // io.vertx.mqtt.MqttAuth auth
        end local 2 // java.lang.String clientIdentifier
        end local 1 // io.vertx.core.net.impl.NetSocketInternal conn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot                     Name  Signature
            0   11     0                     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   11     1                     conn  Lio/vertx/core/net/impl/NetSocketInternal;
            0   11     2         clientIdentifier  Ljava/lang/String;
            0   11     3                     auth  Lio/vertx/mqtt/MqttAuth;
            0   11     4                     will  Lio/vertx/mqtt/MqttWill;
            0   11     5           isCleanSession  Z
            0   11     6          protocolVersion  I
            0   11     7             protocolName  Ljava/lang/String;
            0   11     8  keepAliveTimeoutSeconds  I
    MethodParameters:
                         Name  Flags
      conn                     
      clientIdentifier         
      auth                     
      will                     
      isCleanSession           
      protocolVersion          
      protocolName             
      keepAliveTimeoutSeconds  

  public java.lang.String clientIdentifier();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 127
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.clientIdentifier:Ljava/lang/String;
            areturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public io.vertx.mqtt.MqttAuth auth();
    descriptor: ()Lio/vertx/mqtt/MqttAuth;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 131
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.auth:Lio/vertx/mqtt/MqttAuth;
            areturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public io.vertx.mqtt.MqttWill will();
    descriptor: ()Lio/vertx/mqtt/MqttWill;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 135
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.will:Lio/vertx/mqtt/MqttWill;
            areturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public boolean isCleanSession();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 139
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isCleanSession:Z
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public int protocolVersion();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 143
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.protocolVersion:I
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public java.lang.String protocolName();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 147
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.protocolName:Ljava/lang/String;
            areturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public int keepAliveTimeSeconds();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 151
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.keepAliveTimeoutSeconds:I
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public int lastMessageId();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 155
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.messageIdCounter:I
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public void subscriptionAutoAck(boolean);
    descriptor: (Z)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // boolean isSubscriptionAutoAck
         0: .line 159
            aload 0 /* this */
            iload 1 /* isSubscriptionAutoAck */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isSubscriptionAutoAck:Z
         1: .line 160
            return
        end local 1 // boolean isSubscriptionAutoAck
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0    2     0                   this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    2     1  isSubscriptionAutoAck  Z
    MethodParameters:
                       Name  Flags
      isSubscriptionAutoAck  

  public boolean isSubscriptionAutoAck();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 163
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isSubscriptionAutoAck:Z
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public io.vertx.mqtt.MqttEndpoint publishAutoAck(boolean);
    descriptor: (Z)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // boolean isPublishAutoAck
         0: .line 168
            aload 0 /* this */
            iload 1 /* isPublishAutoAck */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
         1: .line 169
            aload 0 /* this */
            areturn
        end local 1 // boolean isPublishAutoAck
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    2     0              this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    2     1  isPublishAutoAck  Z
    MethodParameters:
                  Name  Flags
      isPublishAutoAck  

  public boolean isPublishAutoAck();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 173
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public io.vertx.mqtt.MqttEndpoint autoKeepAlive(boolean);
    descriptor: (Z)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // boolean isAutoKeepAlive
         0: .line 178
            aload 0 /* this */
            iload 1 /* isAutoKeepAlive */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isAutoKeepAlive:Z
         1: .line 179
            aload 0 /* this */
            areturn
        end local 1 // boolean isAutoKeepAlive
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    2     0             this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    2     1  isAutoKeepAlive  Z
    MethodParameters:
                 Name  Flags
      isAutoKeepAlive  

  public boolean isAutoKeepAlive();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 183
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isAutoKeepAlive:Z
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public boolean isConnected();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 187
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 188
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
            aload 1
            monitorexit
         2: ireturn
         3: .line 187
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         4: athrow
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     2       3  any
           3     4       3  any

  public io.vertx.mqtt.MqttEndpoint setClientIdentifier(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // java.lang.String clientIdentifier
         0: .line 194
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 195
            aload 0 /* this */
            aload 1 /* clientIdentifier */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.clientIdentifier:Ljava/lang/String;
         2: .line 194
            aload 2
            monitorexit
         3: goto 6
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl java.lang.String io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
         4: aload 2
            monitorexit
         5: athrow
         6: .line 197
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 1 // java.lang.String clientIdentifier
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  clientIdentifier  Ljava/lang/String;
      Exception table:
        from    to  target  type
           1     3       4  any
           4     5       4  any
    MethodParameters:
                  Name  Flags
      clientIdentifier  

  public io.vertx.mqtt.impl.MqttEndpointImpl disconnectHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 202
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 203
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 204
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.disconnectHandler:Lio/vertx/core/Handler;
         3: .line 205
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 202
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl subscribeHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttSubscribeMessage>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 211
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 212
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 213
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.subscribeHandler:Lio/vertx/core/Handler;
         3: .line 214
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 211
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubscribeMessage;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubscribeMessage;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl unsubscribeHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttUnsubscribeMessage>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 220
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 221
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 222
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeHandler:Lio/vertx/core/Handler;
         3: .line 223
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 220
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttPublishMessage>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 229
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 230
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 231
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.publishHandler:Lio/vertx/core/Handler;
         3: .line 232
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 229
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishAcknowledgeHandler(io.vertx.core.Handler<java.lang.Integer>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 238
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 239
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 240
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubackHandler:Lio/vertx/core/Handler;
         3: .line 241
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 238
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Integer;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishReceivedHandler(io.vertx.core.Handler<java.lang.Integer>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 247
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 248
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 249
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrecHandler:Lio/vertx/core/Handler;
         3: .line 250
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 247
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Integer;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishReleaseHandler(io.vertx.core.Handler<java.lang.Integer>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 256
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 257
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 258
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrelHandler:Lio/vertx/core/Handler;
         3: .line 259
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 256
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Integer;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishCompletionHandler(io.vertx.core.Handler<java.lang.Integer>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 265
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 266
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 267
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubcompHandler:Lio/vertx/core/Handler;
         3: .line 268
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 265
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Integer;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl pingHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 274
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 275
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 276
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pingreqHandler:Lio/vertx/core/Handler;
         3: .line 277
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 274
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl closeHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 283
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 284
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 285
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.closeHandler:Lio/vertx/core/Handler;
         3: .line 286
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 283
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.mqtt.impl.MqttEndpointImpl exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 292
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 293
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 294
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.exceptionHandler:Lio/vertx/core/Handler;
         3: .line 295
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 292
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  handler  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
         Name  Flags
      handler  

  private io.vertx.mqtt.impl.MqttEndpointImpl connack(io.netty.handler.codec.mqtt.MqttConnectReturnCode, boolean);
    descriptor: (Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;Z)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=6, args_size=3
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode
        start local 2 // boolean sessionPresent
         0: .line 302
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.CONNACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 301
            astore 3 /* fixedHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 304
            new io.netty.handler.codec.mqtt.MqttConnAckVariableHeader
            dup
            aload 1 /* returnCode */
            iload 2 /* sessionPresent */
            invokespecial io.netty.handler.codec.mqtt.MqttConnAckVariableHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;Z)V
         3: .line 303
            astore 4 /* variableHeader */
        start local 4 // io.netty.handler.codec.mqtt.MqttConnAckVariableHeader variableHeader
         4: .line 306
            aload 3 /* fixedHeader */
            aload 4 /* variableHeader */
            aconst_null
            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 /* connack */
        start local 5 // io.netty.handler.codec.mqtt.MqttMessage connack
         5: .line 308
            aload 0 /* this */
            aload 5 /* connack */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         6: .line 311
            aload 1 /* returnCode */
            getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_ACCEPTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            if_acmpeq 9
         7: .line 312
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.close:()V
         8: .line 313
            goto 10
         9: .line 314
      StackMap locals: io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnAckVariableHeader io.netty.handler.codec.mqtt.MqttMessage
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
        10: .line 317
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 5 // io.netty.handler.codec.mqtt.MqttMessage connack
        end local 4 // io.netty.handler.codec.mqtt.MqttConnAckVariableHeader variableHeader
        end local 3 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 2 // boolean sessionPresent
        end local 1 // io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   11     0            this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   11     1      returnCode  Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            0   11     2  sessionPresent  Z
            2   11     3     fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            4   11     4  variableHeader  Lio/netty/handler/codec/mqtt/MqttConnAckVariableHeader;
            5   11     5         connack  Lio/netty/handler/codec/mqtt/MqttMessage;
    MethodParameters:
                Name  Flags
      returnCode      
      sessionPresent  

  public io.vertx.mqtt.MqttEndpoint accept();
    descriptor: ()Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 322
            aload 0 /* this */
            iconst_0
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.accept:(Z)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public io.vertx.mqtt.impl.MqttEndpointImpl accept(boolean);
    descriptor: (Z)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // boolean sessionPresent
         0: .line 327
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 328
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
            ifeq 3
         2: .line 329
            new java.lang.IllegalStateException
            dup
            ldc "Connection already accepted"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 332
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_ACCEPTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            iload 1 /* sessionPresent */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.connack:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;Z)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            aload 2
            monitorexit
         4: areturn
         5: .line 327
      StackMap locals:
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // boolean sessionPresent
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    7     0            this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  sessionPresent  Z
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
                Name  Flags
      sessionPresent  

  public io.vertx.mqtt.impl.MqttEndpointImpl reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode);
    descriptor: (Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode
         0: .line 338
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 339
            aload 1 /* returnCode */
            getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_ACCEPTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            if_acmpne 3
         2: .line 340
            new java.lang.IllegalArgumentException
            dup
            ldc "Need to use the 'accept' method for accepting connection"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 344
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            aload 1 /* returnCode */
            iconst_0
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.connack:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;Z)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            aload 2
            monitorexit
         4: areturn
         5: .line 338
      StackMap locals:
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  returnCode  Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
            Name  Flags
      returnCode  

  public io.vertx.mqtt.impl.MqttEndpointImpl subscribeAcknowledge(int, java.util.List<io.netty.handler.codec.mqtt.MqttQoS>);
    descriptor: (ILjava/util/List;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=7, args_size=3
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int subscribeMessageId
        start local 2 // java.util.List grantedQoSLevels
         0: .line 351
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.SUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 350
            astore 3 /* fixedHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 353
            iload 1 /* subscribeMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 352
            astore 4 /* variableHeader */
        start local 4 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 355
            new io.netty.handler.codec.mqtt.MqttSubAckPayload
            dup
            aload 2 /* grantedQoSLevels */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
            invokedynamic applyAsInt()Ljava/util/function/ToIntFunction;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)I
                  io/netty/handler/codec/mqtt/MqttQoS.value()I (5)
                  (Lio/netty/handler/codec/mqtt/MqttQoS;)I
            invokeinterface java.util.stream.Stream.mapToInt:(Ljava/util/function/ToIntFunction;)Ljava/util/stream/IntStream;
            invokeinterface java.util.stream.IntStream.toArray:()[I
            invokespecial io.netty.handler.codec.mqtt.MqttSubAckPayload.<init>:([I)V
            astore 5 /* payload */
        start local 5 // io.netty.handler.codec.mqtt.MqttSubAckPayload payload
         5: .line 357
            aload 3 /* fixedHeader */
            aload 4 /* variableHeader */
            aload 5 /* payload */
            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 6 /* suback */
        start local 6 // io.netty.handler.codec.mqtt.MqttMessage suback
         6: .line 359
            aload 0 /* this */
            aload 6 /* suback */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         7: .line 361
            aload 0 /* this */
            areturn
        end local 6 // io.netty.handler.codec.mqtt.MqttMessage suback
        end local 5 // io.netty.handler.codec.mqtt.MqttSubAckPayload payload
        end local 4 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
        end local 3 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 2 // java.util.List grantedQoSLevels
        end local 1 // int subscribeMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    8     0                this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    8     1  subscribeMessageId  I
            0    8     2    grantedQoSLevels  Ljava/util/List<Lio/netty/handler/codec/mqtt/MqttQoS;>;
            2    8     3         fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            4    8     4      variableHeader  Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            5    8     5             payload  Lio/netty/handler/codec/mqtt/MqttSubAckPayload;
            6    8     6              suback  Lio/netty/handler/codec/mqtt/MqttMessage;
    Signature: (ILjava/util/List<Lio/netty/handler/codec/mqtt/MqttQoS;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
                    Name  Flags
      subscribeMessageId  
      grantedQoSLevels    

  public io.vertx.mqtt.impl.MqttEndpointImpl unsubscribeAcknowledge(int);
    descriptor: (I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int unsubscribeMessageId
         0: .line 367
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.UNSUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 366
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 369
            iload 1 /* unsubscribeMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 368
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 371
            aload 2 /* fixedHeader */
            aload 3 /* variableHeader */
            aconst_null
            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 4 /* unsuback */
        start local 4 // io.netty.handler.codec.mqtt.MqttMessage unsuback
         5: .line 373
            aload 0 /* this */
            aload 4 /* unsuback */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         6: .line 375
            aload 0 /* this */
            areturn
        end local 4 // io.netty.handler.codec.mqtt.MqttMessage unsuback
        end local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
        end local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 1 // int unsubscribeMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0    7     0                  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  unsubscribeMessageId  I
            2    7     2           fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            4    7     3        variableHeader  Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            5    7     4              unsuback  Lio/netty/handler/codec/mqtt/MqttMessage;
    MethodParameters:
                      Name  Flags
      unsubscribeMessageId  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishAcknowledge(int);
    descriptor: (I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int publishMessageId
         0: .line 381
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 380
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 383
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 382
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 385
            aload 2 /* fixedHeader */
            aload 3 /* variableHeader */
            aconst_null
            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 4 /* puback */
        start local 4 // io.netty.handler.codec.mqtt.MqttMessage puback
         5: .line 387
            aload 0 /* this */
            aload 4 /* puback */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         6: .line 389
            aload 0 /* this */
            areturn
        end local 4 // io.netty.handler.codec.mqtt.MqttMessage puback
        end local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
        end local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 1 // int publishMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  publishMessageId  I
            2    7     2       fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            4    7     3    variableHeader  Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            5    7     4            puback  Lio/netty/handler/codec/mqtt/MqttMessage;
    MethodParameters:
                  Name  Flags
      publishMessageId  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishReceived(int);
    descriptor: (I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int publishMessageId
         0: .line 395
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREC:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 394
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 397
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 396
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 399
            aload 2 /* fixedHeader */
            aload 3 /* variableHeader */
            aconst_null
            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 4 /* pubrec */
        start local 4 // io.netty.handler.codec.mqtt.MqttMessage pubrec
         5: .line 401
            aload 0 /* this */
            aload 4 /* pubrec */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         6: .line 403
            aload 0 /* this */
            areturn
        end local 4 // io.netty.handler.codec.mqtt.MqttMessage pubrec
        end local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
        end local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 1 // int publishMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  publishMessageId  I
            2    7     2       fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            4    7     3    variableHeader  Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            5    7     4            pubrec  Lio/netty/handler/codec/mqtt/MqttMessage;
    MethodParameters:
                  Name  Flags
      publishMessageId  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishRelease(int);
    descriptor: (I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int publishMessageId
         0: .line 409
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREL:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_LEAST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 408
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 411
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 410
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 413
            aload 2 /* fixedHeader */
            aload 3 /* variableHeader */
            aconst_null
            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 4 /* pubrel */
        start local 4 // io.netty.handler.codec.mqtt.MqttMessage pubrel
         5: .line 415
            aload 0 /* this */
            aload 4 /* pubrel */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         6: .line 417
            aload 0 /* this */
            areturn
        end local 4 // io.netty.handler.codec.mqtt.MqttMessage pubrel
        end local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
        end local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 1 // int publishMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  publishMessageId  I
            2    7     2       fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            4    7     3    variableHeader  Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            5    7     4            pubrel  Lio/netty/handler/codec/mqtt/MqttMessage;
    MethodParameters:
                  Name  Flags
      publishMessageId  

  public io.vertx.mqtt.impl.MqttEndpointImpl publishComplete(int);
    descriptor: (I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=5, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int publishMessageId
         0: .line 423
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBCOMP:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 422
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 425
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 424
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 427
            aload 2 /* fixedHeader */
            aload 3 /* variableHeader */
            aconst_null
            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 4 /* pubcomp */
        start local 4 // io.netty.handler.codec.mqtt.MqttMessage pubcomp
         5: .line 429
            aload 0 /* this */
            aload 4 /* pubcomp */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         6: .line 431
            aload 0 /* this */
            areturn
        end local 4 // io.netty.handler.codec.mqtt.MqttMessage pubcomp
        end local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
        end local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 1 // int publishMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    7     0              this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  publishMessageId  I
            2    7     2       fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            4    7     3    variableHeader  Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
            5    7     4           pubcomp  Lio/netty/handler/codec/mqtt/MqttMessage;
    MethodParameters:
                  Name  Flags
      publishMessageId  

  public io.vertx.core.Future<java.lang.Integer> publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean);
    descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=6, args_size=6
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // java.lang.String topic
        start local 2 // io.vertx.core.buffer.Buffer payload
        start local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        start local 4 // boolean isDup
        start local 5 // boolean isRetain
         0: .line 436
            aload 0 /* this */
            aload 1 /* topic */
            aload 2 /* payload */
            aload 3 /* qosLevel */
            iload 4 /* isDup */
            iload 5 /* isRetain */
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.nextMessageId:()I
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZI)Lio/vertx/core/Future;
            areturn
        end local 5 // boolean isRetain
        end local 4 // boolean isDup
        end local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        end local 2 // io.vertx.core.buffer.Buffer payload
        end local 1 // java.lang.String topic
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    1     0      this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    1     1     topic  Ljava/lang/String;
            0    1     2   payload  Lio/vertx/core/buffer/Buffer;
            0    1     3  qosLevel  Lio/netty/handler/codec/mqtt/MqttQoS;
            0    1     4     isDup  Z
            0    1     5  isRetain  Z
    Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)Lio/vertx/core/Future<Ljava/lang/Integer;>;
    MethodParameters:
          Name  Flags
      topic     
      payload   
      qosLevel  
      isDup     
      isRetain  

  public io.vertx.mqtt.impl.MqttEndpointImpl publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=7, args_size=7
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // java.lang.String topic
        start local 2 // io.vertx.core.buffer.Buffer payload
        start local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        start local 4 // boolean isDup
        start local 5 // boolean isRetain
        start local 6 // io.vertx.core.Handler publishSentHandler
         0: .line 441
            aload 0 /* this */
            aload 1 /* topic */
            aload 2 /* payload */
            aload 3 /* qosLevel */
            iload 4 /* isDup */
            iload 5 /* isRetain */
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.nextMessageId:()I
            aload 6 /* publishSentHandler */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZILio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
        end local 6 // io.vertx.core.Handler publishSentHandler
        end local 5 // boolean isRetain
        end local 4 // boolean isDup
        end local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        end local 2 // io.vertx.core.buffer.Buffer payload
        end local 1 // java.lang.String topic
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    1     0                this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    1     1               topic  Ljava/lang/String;
            0    1     2             payload  Lio/vertx/core/buffer/Buffer;
            0    1     3            qosLevel  Lio/netty/handler/codec/mqtt/MqttQoS;
            0    1     4               isDup  Z
            0    1     5            isRetain  Z
            0    1     6  publishSentHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
                    Name  Flags
      topic               
      payload             
      qosLevel            
      isDup               
      isRetain            
      publishSentHandler  

  public io.vertx.core.Future<java.lang.Integer> publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, int);
    descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZI)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=11, args_size=7
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // java.lang.String topic
        start local 2 // io.vertx.core.buffer.Buffer payload
        start local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        start local 4 // boolean isDup
        start local 5 // boolean isRetain
        start local 6 // int messageId
         0: .line 446
            iload 6 /* messageId */
            ldc 65535
            if_icmpgt 1
            iload 6 /* messageId */
            ifge 2
         1: .line 447
      StackMap locals:
      StackMap stack:
            new java.lang.IllegalArgumentException
            dup
            ldc "messageId must be non-negative integer not larger than 65535"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 451
      StackMap locals:
      StackMap stack:
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBLISH:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iload 4 /* isDup */
            aload 3 /* qosLevel */
            iload 5 /* isRetain */
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         3: .line 450
            astore 7 /* fixedHeader */
        start local 7 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         4: .line 453
            new io.netty.handler.codec.mqtt.MqttPublishVariableHeader
            dup
            aload 1 /* topic */
            iload 6 /* messageId */
            invokespecial io.netty.handler.codec.mqtt.MqttPublishVariableHeader.<init>:(Ljava/lang/String;I)V
         5: .line 452
            astore 8 /* variableHeader */
        start local 8 // io.netty.handler.codec.mqtt.MqttPublishVariableHeader variableHeader
         6: .line 455
            aload 2 /* payload */
            invokeinterface io.vertx.core.buffer.Buffer.getBytes:()[B
            invokestatic io.netty.buffer.Unpooled.copiedBuffer:([B)Lio/netty/buffer/ByteBuf;
            astore 9 /* buf */
        start local 9 // io.netty.buffer.ByteBuf buf
         7: .line 457
            aload 7 /* fixedHeader */
            aload 8 /* variableHeader */
            aload 9 /* buf */
            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 10 /* publish */
        start local 10 // io.netty.handler.codec.mqtt.MqttMessage publish
         8: .line 459
            aload 0 /* this */
            aload 10 /* publish */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            aload 8 /* variableHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
        end local 10 // io.netty.handler.codec.mqtt.MqttMessage publish
        end local 9 // io.netty.buffer.ByteBuf buf
        end local 8 // io.netty.handler.codec.mqtt.MqttPublishVariableHeader variableHeader
        end local 7 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 6 // int messageId
        end local 5 // boolean isRetain
        end local 4 // boolean isDup
        end local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        end local 2 // io.vertx.core.buffer.Buffer payload
        end local 1 // java.lang.String topic
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    9     0            this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    9     1           topic  Ljava/lang/String;
            0    9     2         payload  Lio/vertx/core/buffer/Buffer;
            0    9     3        qosLevel  Lio/netty/handler/codec/mqtt/MqttQoS;
            0    9     4           isDup  Z
            0    9     5        isRetain  Z
            0    9     6       messageId  I
            4    9     7     fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            6    9     8  variableHeader  Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
            7    9     9             buf  Lio/netty/buffer/ByteBuf;
            8    9    10         publish  Lio/netty/handler/codec/mqtt/MqttMessage;
    Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZI)Lio/vertx/core/Future<Ljava/lang/Integer;>;
    MethodParameters:
           Name  Flags
      topic      
      payload    
      qosLevel   
      isDup      
      isRetain   
      messageId  

  public io.vertx.mqtt.impl.MqttEndpointImpl publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZILio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=9, args_size=8
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // java.lang.String topic
        start local 2 // io.vertx.core.buffer.Buffer payload
        start local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        start local 4 // boolean isDup
        start local 5 // boolean isRetain
        start local 6 // int messageId
        start local 7 // io.vertx.core.Handler publishSentHandler
         0: .line 464
            aload 0 /* this */
            aload 1 /* topic */
            aload 2 /* payload */
            aload 3 /* qosLevel */
            iload 4 /* isDup */
            iload 5 /* isRetain */
            iload 6 /* messageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZI)Lio/vertx/core/Future;
            astore 8 /* fut */
        start local 8 // io.vertx.core.Future fut
         1: .line 465
            aload 7 /* publishSentHandler */
            ifnull 3
         2: .line 466
            aload 8 /* fut */
            aload 7 /* publishSentHandler */
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 468
      StackMap locals: io.vertx.core.Future
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 8 // io.vertx.core.Future fut
        end local 7 // io.vertx.core.Handler publishSentHandler
        end local 6 // int messageId
        end local 5 // boolean isRetain
        end local 4 // boolean isDup
        end local 3 // io.netty.handler.codec.mqtt.MqttQoS qosLevel
        end local 2 // io.vertx.core.buffer.Buffer payload
        end local 1 // java.lang.String topic
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    4     0                this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    4     1               topic  Ljava/lang/String;
            0    4     2             payload  Lio/vertx/core/buffer/Buffer;
            0    4     3            qosLevel  Lio/netty/handler/codec/mqtt/MqttQoS;
            0    4     4               isDup  Z
            0    4     5            isRetain  Z
            0    4     6           messageId  I
            0    4     7  publishSentHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
            1    4     8                 fut  Lio/vertx/core/Future<Ljava/lang/Integer;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
    MethodParameters:
                    Name  Flags
      topic               
      payload             
      qosLevel            
      isDup               
      isRetain            
      messageId           
      publishSentHandler  

  public io.vertx.mqtt.impl.MqttEndpointImpl pong();
    descriptor: ()Lio/vertx/mqtt/impl/MqttEndpointImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=3, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 474
            new io.netty.handler.codec.mqtt.MqttFixedHeader
            dup
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.PINGRESP:Lio/netty/handler/codec/mqtt/MqttMessageType;
            iconst_0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            iconst_0
            iconst_0
            invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
         1: .line 473
            astore 1 /* fixedHeader */
        start local 1 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 476
            aload 1 /* fixedHeader */
            aconst_null
            aconst_null
            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 2 /* pingresp */
        start local 2 // io.netty.handler.codec.mqtt.MqttMessage pingresp
         3: .line 478
            aload 0 /* this */
            aload 2 /* pingresp */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
            pop
         4: .line 480
            aload 0 /* this */
            areturn
        end local 2 // io.netty.handler.codec.mqtt.MqttMessage pingresp
        end local 1 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    5     0         this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            2    5     1  fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            3    5     2     pingresp  Lio/netty/handler/codec/mqtt/MqttMessage;

  void handleSubscribe(io.vertx.mqtt.messages.MqttSubscribeMessage);
    descriptor: (Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V
    flags: (0x0000) 
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.mqtt.messages.MqttSubscribeMessage msg
         0: .line 490
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 491
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.subscribeHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 492
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.subscribeHandler:Lio/vertx/core/Handler;
            aload 1 /* msg */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 496
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isSubscriptionAutoAck:Z
            ifeq 9
         4: .line 497
            aload 0 /* this */
            aload 1 /* msg */
            invokeinterface io.vertx.mqtt.messages.MqttSubscribeMessage.messageId:()I
            aload 1 /* msg */
            invokeinterface io.vertx.mqtt.messages.MqttSubscribeMessage.topicSubscriptions:()Ljava/util/List;
         5: .line 498
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
         6: .line 499
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  io/vertx/mqtt/MqttTopicSubscription.qualityOfService()Lio/netty/handler/codec/mqtt/MqttQoS; (9 itf)
                  (Lio/vertx/mqtt/MqttTopicSubscription;)Lio/netty/handler/codec/mqtt/MqttQoS;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         7: .line 500
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.List
         8: .line 497
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.subscribeAcknowledge:(ILjava/util/List;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         9: .line 490
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
        10: goto 13
      StackMap locals:
      StackMap stack: java.lang.Throwable
        11: aload 2
            monitorexit
        12: athrow
        13: .line 503
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.mqtt.messages.MqttSubscribeMessage msg
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   14     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   14     1   msg  Lio/vertx/mqtt/messages/MqttSubscribeMessage;
      Exception table:
        from    to  target  type
           1    10      11  any
          11    12      11  any
    MethodParameters:
      Name  Flags
      msg   

  void handleUnsubscribe(io.vertx.mqtt.messages.MqttUnsubscribeMessage);
    descriptor: (Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.mqtt.messages.MqttUnsubscribeMessage msg
         0: .line 512
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 513
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 514
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeHandler:Lio/vertx/core/Handler;
            aload 1 /* msg */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 517
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isSubscriptionAutoAck:Z
            ifeq 5
         4: .line 518
            aload 0 /* this */
            aload 1 /* msg */
            invokeinterface io.vertx.mqtt.messages.MqttUnsubscribeMessage.messageId:()I
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeAcknowledge:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         5: .line 512
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 2
            monitorexit
         8: athrow
         9: .line 521
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.mqtt.messages.MqttUnsubscribeMessage msg
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   10     1   msg  Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;
      Exception table:
        from    to  target  type
           1     6       7  any
           7     8       7  any
    MethodParameters:
      Name  Flags
      msg   

  void handlePublish(io.vertx.mqtt.messages.MqttPublishMessage);
    descriptor: (Lio/vertx/mqtt/messages/MqttPublishMessage;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.vertx.mqtt.messages.MqttPublishMessage msg
         0: .line 530
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 531
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.publishHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 532
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.publishHandler:Lio/vertx/core/Handler;
            aload 1 /* msg */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 535
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
            ifeq 8
         4: .line 537
            invokestatic io.vertx.mqtt.impl.MqttEndpointImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS:()[I
            aload 1 /* msg */
            invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
            invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
            iaload
            tableswitch { // 2 - 3
                    2: 5
                    3: 7
              default: 8
          }
         5: .line 540
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* msg */
            invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.messageId:()I
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishAcknowledge:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         6: .line 541
            goto 8
         7: .line 544
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* msg */
            invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.messageId:()I
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishReceived:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         8: .line 530
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
         9: goto 12
      StackMap locals:
      StackMap stack: java.lang.Throwable
        10: aload 2
            monitorexit
        11: athrow
        12: .line 549
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.mqtt.messages.MqttPublishMessage msg
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   13     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   13     1   msg  Lio/vertx/mqtt/messages/MqttPublishMessage;
      Exception table:
        from    to  target  type
           1     9      10  any
          10    11      10  any
    MethodParameters:
      Name  Flags
      msg   

  void handlePuback(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int pubackMessageId
         0: .line 558
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 559
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubackHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 560
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubackHandler:Lio/vertx/core/Handler;
            iload 1 /* pubackMessageId */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 558
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 563
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubackMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    8     0             this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    8     1  pubackMessageId  I
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
                 Name  Flags
      pubackMessageId  

  void handlePubrec(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int pubrecMessageId
         0: .line 572
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 573
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrecHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 574
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrecHandler:Lio/vertx/core/Handler;
            iload 1 /* pubrecMessageId */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 577
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
            ifeq 5
         4: .line 578
            aload 0 /* this */
            iload 1 /* pubrecMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishRelease:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         5: .line 572
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 2
            monitorexit
         8: athrow
         9: .line 581
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubrecMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0             this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   10     1  pubrecMessageId  I
      Exception table:
        from    to  target  type
           1     6       7  any
           7     8       7  any
    MethodParameters:
                 Name  Flags
      pubrecMessageId  

  void handlePubrel(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int pubrelMessageId
         0: .line 590
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 591
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrelHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 592
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrelHandler:Lio/vertx/core/Handler;
            iload 1 /* pubrelMessageId */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 595
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
            ifeq 5
         4: .line 596
            aload 0 /* this */
            iload 1 /* pubrelMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishComplete:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         5: .line 590
      StackMap locals:
      StackMap stack:
            aload 2
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 2
            monitorexit
         8: athrow
         9: .line 599
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubrelMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0             this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   10     1  pubrelMessageId  I
      Exception table:
        from    to  target  type
           1     6       7  any
           7     8       7  any
    MethodParameters:
                 Name  Flags
      pubrelMessageId  

  void handlePubcomp(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // int pubcompMessageId
         0: .line 608
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 609
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubcompHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 610
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubcompHandler:Lio/vertx/core/Handler;
            iload 1 /* pubcompMessageId */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 608
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 613
      StackMap locals:
      StackMap stack:
            return
        end local 1 // int pubcompMessageId
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    8     0              this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    8     1  pubcompMessageId  I
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
                  Name  Flags
      pubcompMessageId  

  void handlePingreq();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 620
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 622
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pingreqHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 623
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pingreqHandler:Lio/vertx/core/Handler;
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 626
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isAutoKeepAlive:Z
            ifeq 5
         4: .line 627
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.pong:()Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         5: .line 620
      StackMap locals:
      StackMap stack:
            aload 1
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 1
            monitorexit
         8: athrow
         9: .line 630
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     6       7  any
           7     8       7  any

  void handleDisconnect();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 637
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 638
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.disconnectHandler:Lio/vertx/core/Handler;
            ifnull 4
         2: .line 639
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.disconnectHandler:Lio/vertx/core/Handler;
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 642
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.close:()V
         4: .line 637
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 1
            monitorexit
         5: goto 8
      StackMap locals:
      StackMap stack: java.lang.Throwable
         6: aload 1
            monitorexit
         7: athrow
         8: .line 645
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     5       6  any
           6     7       6  any

  void handleClosed();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 652
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 653
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.cleanup:()V
         2: .line 655
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.closeHandler:Lio/vertx/core/Handler;
            ifnull 4
         3: .line 656
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.closeHandler:Lio/vertx/core/Handler;
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         4: .line 652
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 1
            monitorexit
         5: goto 8
      StackMap locals:
      StackMap stack: java.lang.Throwable
         6: aload 1
            monitorexit
         7: athrow
         8: .line 659
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     5       6  any
           6     7       6  any

  void handleException(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // java.lang.Throwable t
         0: .line 668
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 669
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.exceptionHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 670
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.exceptionHandler:Lio/vertx/core/Handler;
            aload 1 /* t */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 668
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 673
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable t
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    8     1     t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    MethodParameters:
      Name  Flags
      t     

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 677
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 678
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 679
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.close:()Lio/vertx/core/Future;
            pop
         3: .line 681
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.cleanup:()V
         4: .line 677
            aload 1
            monitorexit
         5: goto 8
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
         6: aload 1
            monitorexit
         7: athrow
         8: .line 683
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    9     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     5       6  any
           6     7       6  any

  public io.vertx.core.net.SocketAddress localAddress();
    descriptor: ()Lio/vertx/core/net/SocketAddress;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 686
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 687
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 688
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.localAddress:()Lio/vertx/core/net/SocketAddress;
            aload 1
            monitorexit
         3: areturn
         4: .line 686
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         5: athrow
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     3       4  any
           4     5       4  any

  public io.vertx.core.net.SocketAddress remoteAddress();
    descriptor: ()Lio/vertx/core/net/SocketAddress;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 693
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 694
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 695
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.remoteAddress:()Lio/vertx/core/net/SocketAddress;
            aload 1
            monitorexit
         3: areturn
         4: .line 693
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         5: athrow
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     3       4  any
           4     5       4  any

  public boolean isSsl();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 700
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 701
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 702
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.isSsl:()Z
            aload 1
            monitorexit
         3: ireturn
         4: .line 700
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         5: athrow
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     3       4  any
           4     5       4  any

  public javax.net.ssl.SSLSession sslSession();
    descriptor: ()Ljavax/net/ssl/SSLSession;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 707
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 708
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 709
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.sslSession:()Ljavax/net/ssl/SSLSession;
            aload 1
            monitorexit
         3: areturn
         4: .line 707
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.net.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         5: athrow
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
      Exception table:
        from    to  target  type
           1     3       4  any
           4     5       4  any

  private io.vertx.core.Future<java.lang.Void> write(io.netty.handler.codec.mqtt.MqttMessage);
    descriptor: (Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
        start local 1 // io.netty.handler.codec.mqtt.MqttMessage mqttMessage
         0: .line 714
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 715
            aload 1 /* mqttMessage */
            invokevirtual io.netty.handler.codec.mqtt.MqttMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.messageType:()Lio/netty/handler/codec/mqtt/MqttMessageType;
            getstatic io.netty.handler.codec.mqtt.MqttMessageType.CONNACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
            if_acmpeq 3
         2: .line 716
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkConnected:()V
         3: .line 718
      StackMap locals: io.vertx.core.net.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/net/impl/NetSocketInternal;
            aload 1 /* mqttMessage */
            invokeinterface io.vertx.core.net.impl.NetSocketInternal.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/Future;
            aload 2
            monitorexit
         4: areturn
         5: .line 714
      StackMap locals:
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         6: athrow
        end local 1 // io.netty.handler.codec.mqtt.MqttMessage mqttMessage
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    7     0         this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    7     1  mqttMessage  Lio/netty/handler/codec/mqtt/MqttMessage;
      Exception table:
        from    to  target  type
           1     4       5  any
           5     6       5  any
    Signature: (Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
             Name  Flags
      mqttMessage  

  private void checkClosed();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 727
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isClosed:Z
            ifeq 2
         1: .line 728
            new java.lang.IllegalStateException
            dup
            ldc "MQTT endpoint is closed"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 730
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  private void checkConnected();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 737
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
            ifne 2
         1: .line 738
            new java.lang.IllegalStateException
            dup
            ldc "Connection not accepted yet"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 740
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  private void cleanup();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 746
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isClosed:Z
            ifne 3
         1: .line 747
            aload 0 /* this */
            iconst_1
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isClosed:Z
         2: .line 748
            aload 0 /* this */
            iconst_0
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
         3: .line 750
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  private int nextMessageId();
    descriptor: ()I
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
         0: .line 760
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.messageIdCounter:I
            ldc 65535
            irem
            ifeq 1
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.messageIdCounter:I
            iconst_1
            iadd
            goto 2
      StackMap locals:
      StackMap stack: io.vertx.mqtt.impl.MqttEndpointImpl
         1: iconst_1
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl
      StackMap stack: io.vertx.mqtt.impl.MqttEndpointImpl int
         2: putfield io.vertx.mqtt.impl.MqttEndpointImpl.messageIdCounter:I
         3: .line 761
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.messageIdCounter:I
            ireturn
        end local 0 // io.vertx.mqtt.impl.MqttEndpointImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/mqtt/impl/MqttEndpointImpl;

  public io.vertx.mqtt.MqttEndpoint unsubscribeHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint subscribeHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.subscribeHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, int, io.vertx.core.Handler);
    descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZILio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=8, locals=8, args_size=8
         0: .line 1
            aload 0
            aload 1
            aload 2
            aload 3
            iload 4
            iload 5
            iload 6
            aload 7
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZILio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, io.vertx.core.Handler);
    descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=7, locals=7, args_size=7
         0: .line 1
            aload 0
            aload 1
            aload 2
            aload 3
            iload 4
            iload 5
            aload 6
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishRelease(int);
    descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishRelease:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint unsubscribeAcknowledge(int);
    descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeAcknowledge:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint disconnectHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.disconnectHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishReceived(int);
    descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishReceived:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint subscribeAcknowledge(int, java.util.List);
    descriptor: (ILjava/util/List;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            iload 1
            aload 2
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.subscribeAcknowledge:(ILjava/util/List;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode);
    descriptor: (Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.reject:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint pong();
    descriptor: ()Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.pong:()Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint closeHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint pingHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.pingHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishReleaseHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishReleaseHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishAcknowledge(int);
    descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishAcknowledge:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint accept(boolean);
    descriptor: (Z)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.accept:(Z)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishCompletionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishCompletionHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishAcknowledgeHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishAcknowledgeHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishReceivedHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishReceivedHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.mqtt.MqttEndpoint publishComplete(int);
    descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishComplete:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 51
            getstatic io.vertx.mqtt.impl.MqttEndpointImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic io.netty.handler.codec.mqtt.MqttQoS.values:()[Lio/netty/handler/codec/mqtt/MqttQoS;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_LEAST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            invokevirtual io.netty.handler.codec.mqtt.MqttQoS.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.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            invokevirtual io.netty.handler.codec.mqtt.MqttQoS.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.MqttQoS.EXACTLY_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
            invokevirtual io.netty.handler.codec.mqtt.MqttQoS.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.MqttQoS.FAILURE:Lio/netty/handler/codec/mqtt/MqttQoS;
            invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
            iconst_4
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            dup
            putstatic io.vertx.mqtt.impl.MqttEndpointImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS:[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
}
SourceFile: "MqttEndpointImpl.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles