http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-mqtt: Vert.x MQTT reactive client and server (Eclipse) 
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.logging.Logger log;
    descriptor: Lio/vertx/core/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

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

  public void <init>(io.vertx.core.impl.NetSocketInternal, java.lang.String, io.vertx.mqtt.MqttAuth, io.vertx.mqtt.MqttWill, boolean, int, java.lang.String, int);
    descriptor: (Lio/vertx/core/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.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 114
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 100
            aload 0 /* this */
            iconst_1
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isAutoKeepAlive:Z
         2: .line 115
            aload 0 /* this */
            aload 1 /* conn */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
         3: .line 116
            aload 0 /* this */
            aload 2 /* clientIdentifier */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.clientIdentifier:Ljava/lang/String;
         4: .line 117
            aload 0 /* this */
            aload 3 /* auth */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.auth:Lio/vertx/mqtt/MqttAuth;
         5: .line 118
            aload 0 /* this */
            aload 4 /* will */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.will:Lio/vertx/mqtt/MqttWill;
         6: .line 119
            aload 0 /* this */
            iload 5 /* isCleanSession */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isCleanSession:Z
         7: .line 120
            aload 0 /* this */
            iload 6 /* protocolVersion */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.protocolVersion:I
         8: .line 121
            aload 0 /* this */
            aload 7 /* protocolName */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.protocolName:Ljava/lang/String;
         9: .line 122
            aload 0 /* this */
            iload 8 /* keepAliveTimeoutSeconds */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.keepAliveTimeoutSeconds:I
        10: .line 123
            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.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/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 126
            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 130
            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 134
            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 138
            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 142
            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 146
            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 150
            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 154
            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 158
            aload 0 /* this */
            iload 1 /* isSubscriptionAutoAck */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isSubscriptionAutoAck:Z
         1: .line 159
            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 162
            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 167
            aload 0 /* this */
            iload 1 /* isPublishAutoAck */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
         1: .line 168
            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 172
            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 177
            aload 0 /* this */
            iload 1 /* isAutoKeepAlive */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isAutoKeepAlive:Z
         1: .line 178
            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 182
            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 186
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 187
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
            aload 1
            monitorexit
         2: ireturn
         3: .line 186
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.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 193
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 194
            aload 0 /* this */
            aload 1 /* clientIdentifier */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.clientIdentifier:Ljava/lang/String;
         2: .line 193
            aload 2
            monitorexit
         3: goto 6
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl java.lang.String io.vertx.core.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
         4: aload 2
            monitorexit
         5: athrow
         6: .line 196
      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 201
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 202
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 203
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.disconnectHandler:Lio/vertx/core/Handler;
         3: .line 204
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 201
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 210
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 211
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 212
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.subscribeHandler:Lio/vertx/core/Handler;
         3: .line 213
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 210
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 219
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 220
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 221
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeHandler:Lio/vertx/core/Handler;
         3: .line 222
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 219
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 228
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 229
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 230
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.publishHandler:Lio/vertx/core/Handler;
         3: .line 231
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 228
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 237
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 238
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 239
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubackHandler:Lio/vertx/core/Handler;
         3: .line 240
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 237
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 246
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 247
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 248
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrecHandler:Lio/vertx/core/Handler;
         3: .line 249
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 246
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 255
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 256
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 257
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrelHandler:Lio/vertx/core/Handler;
         3: .line 258
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 255
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 264
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 265
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 266
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pubcompHandler:Lio/vertx/core/Handler;
         3: .line 267
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 264
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 273
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 274
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 275
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.pingreqHandler:Lio/vertx/core/Handler;
         3: .line 276
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 273
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 282
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 283
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 284
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.closeHandler:Lio/vertx/core/Handler;
         3: .line 285
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 282
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 291
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 292
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 293
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.exceptionHandler:Lio/vertx/core/Handler;
         3: .line 294
            aload 0 /* this */
            aload 2
            monitorexit
         4: areturn
         5: .line 291
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.Handler io.vertx.core.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 301
            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 300
            astore 3 /* fixedHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 303
            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 302
            astore 4 /* variableHeader */
        start local 4 // io.netty.handler.codec.mqtt.MqttConnAckVariableHeader variableHeader
         4: .line 305
            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 307
            aload 0 /* this */
            aload 5 /* connack */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         6: .line 310
            aload 1 /* returnCode */
            getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_ACCEPTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            if_acmpeq 9
         7: .line 311
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.close:()V
         8: .line 312
            goto 10
         9: .line 313
      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 316
      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 321
            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 326
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 327
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
            ifeq 3
         2: .line 328
            new java.lang.IllegalStateException
            dup
            ldc "Connection already accepted"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 331
      StackMap locals: io.vertx.core.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 326
      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 337
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 338
            aload 1 /* returnCode */
            getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_ACCEPTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
            if_acmpne 3
         2: .line 339
            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 343
      StackMap locals: io.vertx.core.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 337
      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 350
            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 349
            astore 3 /* fixedHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 352
            iload 1 /* subscribeMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 351
            astore 4 /* variableHeader */
        start local 4 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 354
            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 356
            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 358
            aload 0 /* this */
            aload 6 /* suback */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         7: .line 360
            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 366
            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 365
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 368
            iload 1 /* unsubscribeMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 367
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 370
            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 372
            aload 0 /* this */
            aload 4 /* unsuback */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         6: .line 374
            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 380
            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 379
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 382
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 381
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 384
            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 386
            aload 0 /* this */
            aload 4 /* puback */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         6: .line 388
            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 394
            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 393
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 396
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 395
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 398
            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 400
            aload 0 /* this */
            aload 4 /* pubrec */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         6: .line 402
            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 408
            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 407
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 410
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 409
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 412
            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 414
            aload 0 /* this */
            aload 4 /* pubrel */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         6: .line 416
            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 422
            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 421
            astore 2 /* fixedHeader */
        start local 2 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 424
            iload 1 /* publishMessageId */
            invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
         3: .line 423
            astore 3 /* variableHeader */
        start local 3 // io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader variableHeader
         4: .line 426
            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 428
            aload 0 /* this */
            aload 4 /* pubcomp */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         6: .line 430
            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.mqtt.impl.MqttEndpointImpl 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/mqtt/impl/MqttEndpointImpl;
    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 435
            aload 0 /* this */
            aload 1 /* topic */
            aload 2 /* payload */
            aload 3 /* qosLevel */
            iload 4 /* isDup */
            iload 5 /* isRetain */
            aconst_null
            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
        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
    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 440
            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.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=12, 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 445
            iload 6 /* messageId */
            ldc 65535
            if_icmpgt 1
            iload 6 /* messageId */
            ifge 2
         1: .line 446
      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 450
      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 449
            astore 8 /* fixedHeader */
        start local 8 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         4: .line 452
            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 451
            astore 9 /* variableHeader */
        start local 9 // io.netty.handler.codec.mqtt.MqttPublishVariableHeader variableHeader
         6: .line 454
            aload 2 /* payload */
            invokeinterface io.vertx.core.buffer.Buffer.getBytes:()[B
            invokestatic io.netty.buffer.Unpooled.copiedBuffer:([B)Lio/netty/buffer/ByteBuf;
            astore 10 /* buf */
        start local 10 // io.netty.buffer.ByteBuf buf
         7: .line 456
            aload 8 /* fixedHeader */
            aload 9 /* variableHeader */
            aload 10 /* 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 11 /* publish */
        start local 11 // io.netty.handler.codec.mqtt.MqttMessage publish
         8: .line 458
            aload 0 /* this */
            aload 11 /* publish */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         9: .line 460
            aload 7 /* publishSentHandler */
            ifnull 11
        10: .line 461
            aload 7 /* publishSentHandler */
            aload 9 /* variableHeader */
            invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        11: .line 464
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl java.lang.String io.vertx.core.buffer.Buffer io.netty.handler.codec.mqtt.MqttQoS int int int io.vertx.core.Handler io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttPublishVariableHeader io.netty.buffer.ByteBuf io.netty.handler.codec.mqtt.MqttMessage
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 11 // io.netty.handler.codec.mqtt.MqttMessage publish
        end local 10 // io.netty.buffer.ByteBuf buf
        end local 9 // io.netty.handler.codec.mqtt.MqttPublishVariableHeader variableHeader
        end local 8 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
        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   12     0                this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0   12     1               topic  Ljava/lang/String;
            0   12     2             payload  Lio/vertx/core/buffer/Buffer;
            0   12     3            qosLevel  Lio/netty/handler/codec/mqtt/MqttQoS;
            0   12     4               isDup  Z
            0   12     5            isRetain  Z
            0   12     6           messageId  I
            0   12     7  publishSentHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
            4   12     8         fixedHeader  Lio/netty/handler/codec/mqtt/MqttFixedHeader;
            6   12     9      variableHeader  Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
            7   12    10                 buf  Lio/netty/buffer/ByteBuf;
            8   12    11             publish  Lio/netty/handler/codec/mqtt/MqttMessage;
    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 470
            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 469
            astore 1 /* fixedHeader */
        start local 1 // io.netty.handler.codec.mqtt.MqttFixedHeader fixedHeader
         2: .line 472
            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 474
            aload 0 /* this */
            aload 2 /* pingresp */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)V
         4: .line 476
            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 486
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 487
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.subscribeHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 488
            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 492
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isSubscriptionAutoAck:Z
            ifeq 9
         4: .line 493
            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 494
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
         6: .line 495
            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 496
            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 493
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.subscribeAcknowledge:(ILjava/util/List;)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         9: .line 486
      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 499
      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 508
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 509
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.unsubscribeHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 510
            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 513
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isSubscriptionAutoAck:Z
            ifeq 5
         4: .line 514
            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 508
      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 517
      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 526
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 527
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.publishHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 528
            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 531
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
            ifeq 8
         4: .line 533
            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 536
      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 537
            goto 8
         7: .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.publishReceived:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         8: .line 526
      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 545
      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 554
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 555
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubackHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 556
            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 554
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 559
      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 568
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 569
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrecHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 570
            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 573
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
            ifeq 5
         4: .line 574
            aload 0 /* this */
            iload 1 /* pubrecMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishRelease:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         5: .line 568
      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 577
      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 586
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 587
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubrelHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 588
            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 591
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isPublishAutoAck:Z
            ifeq 5
         4: .line 592
            aload 0 /* this */
            iload 1 /* pubrelMessageId */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publishComplete:(I)Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         5: .line 586
      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 595
      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 604
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 605
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pubcompHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 606
            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 604
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 609
      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 616
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 618
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.pingreqHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 619
            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 622
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isAutoKeepAlive:Z
            ifeq 5
         4: .line 623
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.pong:()Lio/vertx/mqtt/impl/MqttEndpointImpl;
            pop
         5: .line 616
      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 626
      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 633
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 634
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.disconnectHandler:Lio/vertx/core/Handler;
            ifnull 4
         2: .line 635
            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 638
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.close:()V
         4: .line 633
      StackMap locals: io.vertx.core.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 641
      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 648
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 649
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.cleanup:()V
         2: .line 651
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.closeHandler:Lio/vertx/core/Handler;
            ifnull 4
         3: .line 652
            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 648
      StackMap locals: io.vertx.core.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 655
      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 664
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 665
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.exceptionHandler:Lio/vertx/core/Handler;
            ifnull 3
         2: .line 666
            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 664
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 2
            monitorexit
         4: goto 7
      StackMap locals:
      StackMap stack: java.lang.Throwable
         5: aload 2
            monitorexit
         6: athrow
         7: .line 669
      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 673
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 674
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 675
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            invokeinterface io.vertx.core.impl.NetSocketInternal.close:()V
         3: .line 677
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.cleanup:()V
         4: .line 673
            aload 1
            monitorexit
         5: goto 8
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.impl.NetSocketInternal
      StackMap stack: java.lang.Throwable
         6: aload 1
            monitorexit
         7: athrow
         8: .line 679
      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 682
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 683
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 684
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            invokeinterface io.vertx.core.impl.NetSocketInternal.localAddress:()Lio/vertx/core/net/SocketAddress;
            aload 1
            monitorexit
         3: areturn
         4: .line 682
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.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 689
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 690
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 691
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            invokeinterface io.vertx.core.impl.NetSocketInternal.remoteAddress:()Lio/vertx/core/net/SocketAddress;
            aload 1
            monitorexit
         3: areturn
         4: .line 689
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.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 696
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 697
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 698
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            invokeinterface io.vertx.core.impl.NetSocketInternal.isSsl:()Z
            aload 1
            monitorexit
         3: ireturn
         4: .line 696
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.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 703
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 1
            monitorenter
         1: .line 704
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkClosed:()V
         2: .line 705
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            invokeinterface io.vertx.core.impl.NetSocketInternal.sslSession:()Ljavax/net/ssl/SSLSession;
            aload 1
            monitorexit
         3: areturn
         4: .line 703
      StackMap locals: io.vertx.mqtt.impl.MqttEndpointImpl io.vertx.core.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 void write(io.netty.handler.codec.mqtt.MqttMessage);
    descriptor: (Lio/netty/handler/codec/mqtt/MqttMessage;)V
    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 710
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            dup
            astore 2
            monitorenter
         1: .line 711
            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 712
            aload 0 /* this */
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.checkConnected:()V
         3: .line 714
      StackMap locals: io.vertx.core.impl.NetSocketInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.conn:Lio/vertx/core/impl/NetSocketInternal;
            aload 1 /* mqttMessage */
            invokeinterface io.vertx.core.impl.NetSocketInternal.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/impl/NetSocketInternal;
            pop
         4: .line 710
            aload 2
            monitorexit
         5: goto 8
      StackMap locals:
      StackMap stack: java.lang.Throwable
         6: aload 2
            monitorexit
         7: athrow
         8: .line 716
      StackMap locals:
      StackMap stack:
            return
        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    9     0         this  Lio/vertx/mqtt/impl/MqttEndpointImpl;
            0    9     1  mqttMessage  Lio/netty/handler/codec/mqtt/MqttMessage;
      Exception table:
        from    to  target  type
           1     5       6  any
           6     7       6  any
    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 723
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isClosed:Z
            ifeq 2
         1: .line 724
            new java.lang.IllegalStateException
            dup
            ldc "MQTT endpoint is closed"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 726
      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 733
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
            ifne 2
         1: .line 734
            new java.lang.IllegalStateException
            dup
            ldc "Connection not accepted yet"
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 736
      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 742
            aload 0 /* this */
            getfield io.vertx.mqtt.impl.MqttEndpointImpl.isClosed:Z
            ifne 3
         1: .line 743
            aload 0 /* this */
            iconst_1
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isClosed:Z
         2: .line 744
            aload 0 /* this */
            iconst_0
            putfield io.vertx.mqtt.impl.MqttEndpointImpl.isConnected:Z
         3: .line 746
      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 756
            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 757
            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 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/mqtt/MqttEndpoint;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=6, locals=6, args_size=6
         0: .line 1
            aload 0
            aload 1
            aload 2
            aload 3
            iload 4
            iload 5
            invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)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 50
            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