public class io.vertx.ext.stomp.impl.StompClientImpl implements io.vertx.ext.stomp.StompClient
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.ext.stomp.impl.StompClientImpl
  super_class: java.lang.Object
{
  private static final io.vertx.core.impl.logging.Logger log;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final io.vertx.core.Vertx vertx;
    descriptor: Lio/vertx/core/Vertx;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.ext.stomp.StompClientOptions options;
    descriptor: Lio/vertx/ext/stomp/StompClientOptions;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private io.vertx.core.net.NetClient client;
    descriptor: Lio/vertx/core/net/NetClient;
    flags: (0x0002) ACC_PRIVATE

  private io.vertx.core.Handler<io.vertx.ext.stomp.Frame> receivedFrameHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;

  private io.vertx.core.Handler<io.vertx.ext.stomp.Frame> writingFrameHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;

  private io.vertx.core.Handler<io.vertx.ext.stomp.Frame> errorFrameHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;

  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;>;

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

  public void <init>(io.vertx.core.Vertx, io.vertx.ext.stomp.StompClientOptions);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/ext/stomp/StompClientOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.vertx.ext.stomp.StompClientOptions options
         0: .line 51
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 52
            aload 0 /* this */
            aload 1 /* vertx */
            putfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
         2: .line 53
            aload 0 /* this */
            aload 2 /* options */
            putfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
         3: .line 54
            return
        end local 2 // io.vertx.ext.stomp.StompClientOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    4     1    vertx  Lio/vertx/core/Vertx;
            0    4     2  options  Lio/vertx/ext/stomp/StompClientOptions;
    MethodParameters:
         Name  Flags
      vertx    
      options  

  public io.vertx.ext.stomp.StompClient connect(int, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.stomp.StompClientConnection>>);
    descriptor: (ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // int port
        start local 2 // java.lang.String host
        start local 3 // io.vertx.core.Handler resultHandler
         0: .line 58
            aload 0 /* this */
            iload 1 /* port */
            aload 2 /* host */
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokeinterface io.vertx.core.Vertx.createNetClient:(Lio/vertx/core/net/NetClientOptions;)Lio/vertx/core/net/NetClient;
            aload 3 /* resultHandler */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.connect:(ILjava/lang/String;Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
            areturn
        end local 3 // io.vertx.core.Handler resultHandler
        end local 2 // java.lang.String host
        end local 1 // int port
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    1     0           this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    1     1           port  I
            0    1     2           host  Ljava/lang/String;
            0    1     3  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;
    Signature: (ILjava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
               Name  Flags
      port           
      host           
      resultHandler  

  public io.vertx.ext.stomp.StompClient connect(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.stomp.StompClientConnection>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.Handler resultHandler
         0: .line 63
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getPort:()I
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getHost:()Ljava/lang/String;
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokeinterface io.vertx.core.Vertx.createNetClient:(Lio/vertx/core/net/NetClientOptions;)Lio/vertx/core/net/NetClient;
            aload 1 /* resultHandler */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.connect:(ILjava/lang/String;Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
            areturn
        end local 1 // io.vertx.core.Handler resultHandler
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    1     0           this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    1     1  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
               Name  Flags
      resultHandler  

  public io.vertx.core.Future<io.vertx.ext.stomp.StompClientConnection> connect();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
         0: .line 68
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 69
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.connect:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
            pop
         2: .line 70
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            1    3     1  promise  Lio/vertx/core/Promise<Lio/vertx/ext/stomp/StompClientConnection;>;
    Signature: ()Lio/vertx/core/Future<Lio/vertx/ext/stomp/StompClientConnection;>;

  public synchronized io.vertx.ext.stomp.StompClient receivedFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 82
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.ext.stomp.impl.StompClientImpl.receivedFrameHandler:Lio/vertx/core/Handler;
         1: .line 83
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
         Name  Flags
      handler  

  public synchronized io.vertx.ext.stomp.StompClient writingFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 98
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.ext.stomp.impl.StompClientImpl.writingFrameHandler:Lio/vertx/core/Handler;
         1: .line 99
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
         Name  Flags
      handler  

  public synchronized io.vertx.ext.stomp.StompClient errorFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 112
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.ext.stomp.impl.StompClientImpl.errorFrameHandler:Lio/vertx/core/Handler;
         1: .line 113
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
         Name  Flags
      handler  

  public synchronized io.vertx.ext.stomp.StompClient exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 124
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.ext.stomp.impl.StompClientImpl.exceptionHandler:Lio/vertx/core/Handler;
         1: .line 125
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.ext.stomp.StompClient connect(io.vertx.core.net.NetClient, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.stomp.StompClientConnection>>);
    descriptor: (Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.net.NetClient netClient
        start local 2 // io.vertx.core.Handler resultHandler
         0: .line 130
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getPort:()I
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getHost:()Ljava/lang/String;
            aload 1 /* netClient */
            aload 2 /* resultHandler */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.connect:(ILjava/lang/String;Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
            areturn
        end local 2 // io.vertx.core.Handler resultHandler
        end local 1 // io.vertx.core.net.NetClient netClient
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    1     0           this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    1     1      netClient  Lio/vertx/core/net/NetClient;
            0    1     2  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;
    Signature: (Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
               Name  Flags
      netClient      
      resultHandler  

  public io.vertx.core.Future<io.vertx.ext.stomp.StompClientConnection> connect(io.vertx.core.net.NetClient);
    descriptor: (Lio/vertx/core/net/NetClient;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // io.vertx.core.net.NetClient net
         0: .line 135
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 136
            aload 0 /* this */
            aload 1 /* net */
            aload 2 /* promise */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.connect:(Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
            pop
         2: .line 137
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // io.vertx.core.net.NetClient net
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    3     1      net  Lio/vertx/core/net/NetClient;
            1    3     2  promise  Lio/vertx/core/Promise<Lio/vertx/ext/stomp/StompClientConnection;>;
    Signature: (Lio/vertx/core/net/NetClient;)Lio/vertx/core/Future<Lio/vertx/ext/stomp/StompClientConnection;>;
    MethodParameters:
      Name  Flags
      net   

  public io.vertx.core.Future<io.vertx.ext.stomp.StompClientConnection> connect(int, java.lang.String);
    descriptor: (ILjava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // int port
        start local 2 // java.lang.String host
         0: .line 142
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 3 /* promise */
        start local 3 // io.vertx.core.Promise promise
         1: .line 143
            aload 0 /* this */
            iload 1 /* port */
            aload 2 /* host */
            aload 3 /* promise */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.connect:(ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
            pop
         2: .line 144
            aload 3 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 3 // io.vertx.core.Promise promise
        end local 2 // java.lang.String host
        end local 1 // int port
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    3     1     port  I
            0    3     2     host  Ljava/lang/String;
            1    3     3  promise  Lio/vertx/core/Promise<Lio/vertx/ext/stomp/StompClientConnection;>;
    Signature: (ILjava/lang/String;)Lio/vertx/core/Future<Lio/vertx/ext/stomp/StompClientConnection;>;
    MethodParameters:
      Name  Flags
      port  
      host  

  public synchronized void close();
    descriptor: ()V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
         0: .line 149
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
            ifnull 3
         1: .line 150
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
            invokeinterface io.vertx.core.net.NetClient.close:()Lio/vertx/core/Future;
            pop
         2: .line 151
            aload 0 /* this */
            aconst_null
            putfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
         3: .line 153
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/ext/stomp/impl/StompClientImpl;

  public io.vertx.ext.stomp.StompClientOptions options();
    descriptor: ()Lio/vertx/ext/stomp/StompClientOptions;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
         0: .line 158
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            areturn
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/ext/stomp/impl/StompClientImpl;

  public io.vertx.core.Vertx vertx();
    descriptor: ()Lio/vertx/core/Vertx;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
         0: .line 163
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
            areturn
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/ext/stomp/impl/StompClientImpl;

  public synchronized boolean isClosed();
    descriptor: ()Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
         0: .line 168
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
            ifnonnull 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/ext/stomp/impl/StompClientImpl;

  public synchronized io.vertx.ext.stomp.StompClient connect(int, java.lang.String, io.vertx.core.net.NetClient, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.stomp.StompClientConnection>>);
    descriptor: (ILjava/lang/String;Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=10, locals=8, args_size=5
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // int port
        start local 2 // java.lang.String host
        start local 3 // io.vertx.core.net.NetClient net
        start local 4 // io.vertx.core.Handler resultHandler
         0: .line 173
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
            ifnull 3
         1: .line 174
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
            invokeinterface io.vertx.core.net.NetClient.close:()Lio/vertx/core/Future;
            pop
         2: .line 175
            aload 0 /* this */
            aconst_null
            putfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
         3: .line 178
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.receivedFrameHandler:Lio/vertx/core/Handler;
            astore 5 /* r */
        start local 5 // io.vertx.core.Handler r
         4: .line 179
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.writingFrameHandler:Lio/vertx/core/Handler;
            astore 6 /* w */
        start local 6 // io.vertx.core.Handler w
         5: .line 180
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.exceptionHandler:Lio/vertx/core/Handler;
            astore 7 /* err */
        start local 7 // io.vertx.core.Handler err
         6: .line 181
            aload 3 /* net */
            iload 1 /* port */
            aload 2 /* host */
            aload 0 /* this */
            aload 3 /* net */
            aload 4 /* resultHandler */
            aload 5 /* r */
            aload 6 /* w */
            aload 7 /* err */
            aload 2 /* host */
            invokedynamic handle(Lio/vertx/ext/stomp/impl/StompClientImpl;Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Ljava/lang/String;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/ext/stomp/impl/StompClientImpl.lambda$0(Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.net.NetClient.connect:(ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetClient;
            pop
         7: .line 226
            aload 0 /* this */
            areturn
        end local 7 // io.vertx.core.Handler err
        end local 6 // io.vertx.core.Handler w
        end local 5 // io.vertx.core.Handler r
        end local 4 // io.vertx.core.Handler resultHandler
        end local 3 // io.vertx.core.net.NetClient net
        end local 2 // java.lang.String host
        end local 1 // int port
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    8     0           this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    8     1           port  I
            0    8     2           host  Ljava/lang/String;
            0    8     3            net  Lio/vertx/core/net/NetClient;
            0    8     4  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;
            4    8     5              r  Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
            5    8     6              w  Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
            6    8     7            err  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
    Signature: (ILjava/lang/String;Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;)Lio/vertx/ext/stomp/StompClient;
    MethodParameters:
               Name  Flags
      port           
      host           
      net            
      resultHandler  

  public io.vertx.core.Future<io.vertx.ext.stomp.StompClientConnection> connect(int, java.lang.String, io.vertx.core.net.NetClient);
    descriptor: (ILjava/lang/String;Lio/vertx/core/net/NetClient;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // int port
        start local 2 // java.lang.String host
        start local 3 // io.vertx.core.net.NetClient net
         0: .line 231
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 4 /* promise */
        start local 4 // io.vertx.core.Promise promise
         1: .line 232
            aload 0 /* this */
            iload 1 /* port */
            aload 2 /* host */
            aload 3 /* net */
            aload 4 /* promise */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.connect:(ILjava/lang/String;Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClient;
            pop
         2: .line 233
            aload 4 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 4 // io.vertx.core.Promise promise
        end local 3 // io.vertx.core.net.NetClient net
        end local 2 // java.lang.String host
        end local 1 // int port
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0    3     1     port  I
            0    3     2     host  Ljava/lang/String;
            0    3     3      net  Lio/vertx/core/net/NetClient;
            1    3     4  promise  Lio/vertx/core/Promise<Lio/vertx/ext/stomp/StompClientConnection;>;
    Signature: (ILjava/lang/String;Lio/vertx/core/net/NetClient;)Lio/vertx/core/Future<Lio/vertx/ext/stomp/StompClientConnection;>;
    MethodParameters:
      Name  Flags
      port  
      host  
      net   

  private io.vertx.ext.stomp.Frame getConnectFrame(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 1 // java.lang.String host
         0: .line 237
            invokestatic io.vertx.ext.stomp.utils.Headers.create:()Lio/vertx/ext/stomp/utils/Headers;
            astore 2 /* headers */
        start local 2 // io.vertx.ext.stomp.utils.Headers headers
         1: .line 238
            aload 0 /* this */
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.getAcceptedVersions:()Ljava/lang/String;
            astore 3 /* accepted */
        start local 3 // java.lang.String accepted
         2: .line 239
            aload 3 /* accepted */
            ifnull 4
         3: .line 240
            aload 2 /* headers */
            ldc "accept-version"
            aload 3 /* accepted */
            invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 242
      StackMap locals: io.vertx.ext.stomp.utils.Headers java.lang.String
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.isBypassHostHeader:()Z
            ifne 6
         5: .line 243
            aload 2 /* headers */
            ldc "host"
            aload 1 /* host */
            invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 245
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getVirtualHost:()Ljava/lang/String;
            ifnull 8
         7: .line 246
            aload 2 /* headers */
            ldc "host"
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getVirtualHost:()Ljava/lang/String;
            invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         8: .line 248
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getLogin:()Ljava/lang/String;
            ifnull 10
         9: .line 249
            aload 2 /* headers */
            ldc "login"
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getLogin:()Ljava/lang/String;
            invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        10: .line 251
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getPasscode:()Ljava/lang/String;
            ifnull 12
        11: .line 252
            aload 2 /* headers */
            ldc "passcode"
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getPasscode:()Ljava/lang/String;
            invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        12: .line 254
      StackMap locals:
      StackMap stack:
            aload 2 /* headers */
            ldc "heart-beat"
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getHeartbeat:()Lio/vertx/core/json/JsonObject;
            invokestatic io.vertx.ext.stomp.Frame$Heartbeat.create:(Lio/vertx/core/json/JsonObject;)Lio/vertx/ext/stomp/Frame$Heartbeat;
            invokevirtual io.vertx.ext.stomp.Frame$Heartbeat.toString:()Ljava/lang/String;
            invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        13: .line 256
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.isUseStompFrame:()Z
            ifeq 14
            getstatic io.vertx.ext.stomp.Frame$Command.STOMP:Lio/vertx/ext/stomp/Frame$Command;
            goto 15
      StackMap locals:
      StackMap stack:
        14: getstatic io.vertx.ext.stomp.Frame$Command.CONNECT:Lio/vertx/ext/stomp/Frame$Command;
      StackMap locals:
      StackMap stack: io.vertx.ext.stomp.Frame$Command
        15: astore 4 /* cmd */
        start local 4 // io.vertx.ext.stomp.Frame$Command cmd
        16: .line 257
            new io.vertx.ext.stomp.Frame
            dup
            aload 4 /* cmd */
            aload 2 /* headers */
            aconst_null
            invokespecial io.vertx.ext.stomp.Frame.<init>:(Lio/vertx/ext/stomp/Frame$Command;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;)V
            areturn
        end local 4 // io.vertx.ext.stomp.Frame$Command cmd
        end local 3 // java.lang.String accepted
        end local 2 // io.vertx.ext.stomp.utils.Headers headers
        end local 1 // java.lang.String host
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   17     0      this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0   17     1      host  Ljava/lang/String;
            1   17     2   headers  Lio/vertx/ext/stomp/utils/Headers;
            2   17     3  accepted  Ljava/lang/String;
           16   17     4       cmd  Lio/vertx/ext/stomp/Frame$Command;
    MethodParameters:
      Name  Flags
      host  

  private java.lang.String getAcceptedVersions();
    descriptor: ()Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
         0: .line 261
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getAcceptedVersions:()Ljava/util/List;
            ifnull 1
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getAcceptedVersions:()Ljava/util/List;
            invokeinterface java.util.List.isEmpty:()Z
            ifeq 2
         1: .line 262
      StackMap locals:
      StackMap stack:
            aconst_null
            areturn
         2: .line 264
      StackMap locals:
      StackMap stack:
            new java.lang.StringBuilder
            dup
            invokespecial java.lang.StringBuilder.<init>:()V
            astore 1 /* builder */
        start local 1 // java.lang.StringBuilder builder
         3: .line 265
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getAcceptedVersions:()Ljava/util/List;
         4: .line 266
            aload 1 /* builder */
            invokedynamic accept(Ljava/lang/StringBuilder;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/ext/stomp/impl/StompClientImpl.lambda$3(Ljava/lang/StringBuilder;Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
         5: .line 265
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
         6: .line 268
            aload 1 /* builder */
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
        end local 1 // java.lang.StringBuilder builder
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            3    7     1  builder  Ljava/lang/StringBuilder;

  private void lambda$0(io.vertx.core.net.NetClient, io.vertx.core.Handler, io.vertx.core.Handler, io.vertx.core.Handler, io.vertx.core.Handler, java.lang.String, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/net/NetClient;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=10, args_size=8
        start local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
        start local 7 // io.vertx.core.AsyncResult ar
         0: .line 182
            aload 0 /* this */
            dup
            astore 8
            monitorenter
         1: .line 183
            aload 0 /* this */
            aload 7 /* ar */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 2
            aconst_null
            goto 3
      StackMap locals: io.vertx.ext.stomp.impl.StompClientImpl io.vertx.core.net.NetClient io.vertx.core.Handler io.vertx.core.Handler io.vertx.core.Handler io.vertx.core.Handler java.lang.String io.vertx.core.AsyncResult io.vertx.ext.stomp.impl.StompClientImpl
      StackMap stack: io.vertx.ext.stomp.impl.StompClientImpl
         2: aload 1
      StackMap locals: io.vertx.ext.stomp.impl.StompClientImpl io.vertx.core.net.NetClient io.vertx.core.Handler io.vertx.core.Handler io.vertx.core.Handler io.vertx.core.Handler java.lang.String io.vertx.core.AsyncResult io.vertx.ext.stomp.impl.StompClientImpl
      StackMap stack: io.vertx.ext.stomp.impl.StompClientImpl io.vertx.core.net.NetClient
         3: putfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
         4: .line 184
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
            ifnull 6
         5: .line 185
            aload 7 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.core.net.NetSocket
            aload 2
            invokedynamic handle(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/ext/stomp/impl/StompClientImpl.lambda$1(Lio/vertx/core/Handler;Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.net.NetSocket.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
            pop
         6: .line 182
      StackMap locals:
      StackMap stack:
            aload 8
            monitorexit
         7: goto 10
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: aload 8
            monitorexit
         9: athrow
        10: .line 195
      StackMap locals:
      StackMap stack:
            aload 7 /* ar */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 16
        11: .line 196
            aload 2
            ifnull 14
        12: .line 197
            aload 2
            aload 7 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        13: .line 198
            goto 27
        14: .line 199
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.ext.stomp.impl.StompClientImpl.log:Lio/vertx/core/impl/logging/Logger;
            ldc "Unable to connect to the server"
            aload 7 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        15: .line 201
            goto 27
        16: .line 203
      StackMap locals:
      StackMap stack:
            new io.vertx.ext.stomp.impl.StompClientConnectionImpl
            dup
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
            aload 7 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.core.net.NetSocket
            aload 0 /* this */
            aload 2
            invokespecial io.vertx.ext.stomp.impl.StompClientConnectionImpl.<init>:(Lio/vertx/core/Vertx;Lio/vertx/core/net/NetSocket;Lio/vertx/ext/stomp/StompClient;Lio/vertx/core/Handler;)V
        17: .line 204
            aload 3
            invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.receivedFrameHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
        18: .line 205
            aload 4
            invokeinterface io.vertx.ext.stomp.StompClientConnection.writingFrameHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
        19: .line 206
            aload 5
            invokeinterface io.vertx.ext.stomp.StompClientConnection.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
        20: .line 207
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.errorFrameHandler:Lio/vertx/core/Handler;
            invokeinterface io.vertx.ext.stomp.StompClientConnection.errorHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
        21: .line 203
            astore 8 /* stompClientConnection */
        start local 8 // io.vertx.ext.stomp.StompClientConnection stompClientConnection
        22: .line 209
            aload 0 /* this */
            aload 6
            invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.getConnectFrame:(Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
            astore 9 /* frame */
        start local 9 // io.vertx.ext.stomp.Frame frame
        23: .line 212
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.getConnectTimeout:()I
            i2l
            aload 8 /* stompClientConnection */
            aload 2
            invokedynamic handle(Lio/vertx/ext/stomp/StompClientConnection;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/ext/stomp/impl/StompClientImpl.lambda$2(Lio/vertx/ext/stomp/StompClientConnection;Lio/vertx/core/Handler;Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
            pop2
        24: .line 219
            aload 4
            ifnull 26
        25: .line 220
            aload 4
            aload 9 /* frame */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        26: .line 223
      StackMap locals: io.vertx.ext.stomp.StompClientConnection io.vertx.ext.stomp.Frame
      StackMap stack:
            aload 7 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.core.net.NetSocket
            aload 9 /* frame */
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
            invokevirtual io.vertx.ext.stomp.StompClientOptions.isTrailingLine:()Z
            invokevirtual io.vertx.ext.stomp.Frame.toBuffer:(Z)Lio/vertx/core/buffer/Buffer;
            invokeinterface io.vertx.core.net.NetSocket.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
            pop
        end local 9 // io.vertx.ext.stomp.Frame frame
        end local 8 // io.vertx.ext.stomp.StompClientConnection stompClientConnection
        27: .line 225
      StackMap locals:
      StackMap stack:
            return
        end local 7 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.ext.stomp.impl.StompClientImpl this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0   28     0                   this  Lio/vertx/ext/stomp/impl/StompClientImpl;
            0   28     7                     ar  Lio/vertx/core/AsyncResult<Lio/vertx/core/net/NetSocket;>;
           22   27     8  stompClientConnection  Lio/vertx/ext/stomp/StompClientConnection;
           23   27     9                  frame  Lio/vertx/ext/stomp/Frame;
      Exception table:
        from    to  target  type
           1     7       8  any
           8     9       8  any

  private static void lambda$3(java.lang.StringBuilder, java.lang.String);
    descriptor: (Ljava/lang/StringBuilder;Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 1 // java.lang.String version
         0: .line 266
            aload 0
            aload 0
            invokevirtual java.lang.StringBuilder.length:()I
            ifne 1
            aload 1 /* version */
            goto 2
      StackMap locals:
      StackMap stack: java.lang.StringBuilder
         1: new java.lang.StringBuilder
            dup
            ldc ","
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* version */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
      StackMap locals: java.lang.StringBuilder java.lang.String
      StackMap stack: java.lang.StringBuilder java.lang.String
         2: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            return
        end local 1 // java.lang.String version
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     1  version  Ljava/lang/String;

  private static void lambda$1(io.vertx.core.Handler, java.lang.Throwable);
    descriptor: (Lio/vertx/core/Handler;Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 1 // java.lang.Throwable t
         0: .line 186
            aload 0
            ifnull 3
         1: .line 187
            aload 0
            aload 1 /* t */
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         2: .line 188
            goto 4
         3: .line 189
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.ext.stomp.impl.StompClientImpl.log:Lio/vertx/core/impl/logging/Logger;
            ldc "Unable to connect to the server"
            aload 1 /* t */
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         4: .line 191
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable t
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     1     t  Ljava/lang/Throwable;

  private static void lambda$2(io.vertx.ext.stomp.StompClientConnection, io.vertx.core.Handler, java.lang.Long);
    descriptor: (Lio/vertx/ext/stomp/StompClientConnection;Lio/vertx/core/Handler;Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // java.lang.Long l
         0: .line 213
            aload 0
            invokeinterface io.vertx.ext.stomp.StompClientConnection.isConnected:()Z
            ifne 3
         1: .line 214
            aload 1
            ldc "CONNECTED frame not receive in time"
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         2: .line 215
            aload 0
            invokeinterface io.vertx.ext.stomp.StompClientConnection.close:()V
         3: .line 217
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Long l
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     2     l  Ljava/lang/Long;
}
SourceFile: "StompClientImpl.java"
InnerClasses:
  public final Command = io.vertx.ext.stomp.Frame$Command of io.vertx.ext.stomp.Frame
  public Heartbeat = io.vertx.ext.stomp.Frame$Heartbeat of io.vertx.ext.stomp.Frame
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles