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.logging.Logger log;
descriptor: Lio/vertx/core/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: ldc Lio/vertx/ext/stomp/impl/StompClientImpl;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.ext.stomp.impl.StompClientImpl.log:Lio/vertx/core/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 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
2: aload 0
aload 2
putfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
3: return
end local 2 end local 1 end local 0 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 start local 1 start local 2 start local 3 0: aload 0
iload 1
aload 2
aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
aload 0
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
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 end local 2 end local 1 end local 0 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 start local 1 0: aload 0
aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
invokevirtual io.vertx.ext.stomp.StompClientOptions.getPort:()I
aload 0
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
getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
aload 0
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
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 end local 0 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 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 start local 1 0: aload 0
aload 1
putfield io.vertx.ext.stomp.impl.StompClientImpl.receivedFrameHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 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 start local 1 0: aload 0
aload 1
putfield io.vertx.ext.stomp.impl.StompClientImpl.writingFrameHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 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 start local 1 0: aload 0
aload 1
putfield io.vertx.ext.stomp.impl.StompClientImpl.errorFrameHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 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 start local 1 0: aload 0
aload 1
putfield io.vertx.ext.stomp.impl.StompClientImpl.exceptionHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 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 start local 1 start local 2 0: aload 0
aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
invokevirtual io.vertx.ext.stomp.StompClientOptions.getPort:()I
aload 0
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
aload 2
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 end local 1 end local 0 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 synchronized void close();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
ifnull 3
1: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
invokeinterface io.vertx.core.net.NetClient.close:()V
2: aload 0
aconst_null
putfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
3: StackMap locals:
StackMap stack:
return
end local 0 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 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
areturn
end local 0 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 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
areturn
end local 0 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 0: aload 0
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 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 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
ifnull 3
1: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
invokeinterface io.vertx.core.net.NetClient.close:()V
2: aload 0
aconst_null
putfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.receivedFrameHandler:Lio/vertx/core/Handler;
astore 5
start local 5 4: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.writingFrameHandler:Lio/vertx/core/Handler;
astore 6
start local 6 5: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.exceptionHandler:Lio/vertx/core/Handler;
astore 7
start local 7 6: aload 3
iload 1
aload 2
aload 0
aload 3
aload 4
aload 5
aload 6
aload 7
aload 2
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: aload 0
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 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
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 start local 1 0: invokestatic io.vertx.ext.stomp.utils.Headers.create:()Lio/vertx/ext/stomp/utils/Headers;
astore 2
start local 2 1: aload 0
invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.getAcceptedVersions:()Ljava/lang/String;
astore 3
start local 3 2: aload 3
ifnull 4
3: aload 2
ldc "accept-version"
aload 3
invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: StackMap locals: io.vertx.ext.stomp.utils.Headers java.lang.String
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
invokevirtual io.vertx.ext.stomp.StompClientOptions.isBypassHostHeader:()Z
ifne 6
5: aload 2
ldc "host"
aload 1
invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: StackMap locals:
StackMap stack:
aload 0
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: aload 2
ldc "host"
aload 0
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: StackMap locals:
StackMap stack:
aload 0
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: aload 2
ldc "login"
aload 0
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: StackMap locals:
StackMap stack:
aload 0
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: aload 2
ldc "passcode"
aload 0
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: StackMap locals:
StackMap stack:
aload 2
ldc "heart-beat"
aload 0
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: aload 0
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
start local 4 16: new io.vertx.ext.stomp.Frame
dup
aload 4
aload 2
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 end local 3 end local 2 end local 1 end local 0 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 0: aload 0
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
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: StackMap locals:
StackMap stack:
aconst_null
areturn
2: StackMap locals:
StackMap stack:
new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
astore 1
start local 1 3: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
invokevirtual io.vertx.ext.stomp.StompClientOptions.getAcceptedVersions:()Ljava/util/List;
4: aload 1
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: invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
6: aload 1
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 1 end local 0 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 start local 7 0: aload 0
dup
astore 8
monitorenter
1: aload 0
aload 7
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: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.client:Lio/vertx/core/net/NetClient;
ifnull 6
5: aload 7
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: StackMap locals:
StackMap stack:
aload 8
monitorexit
7: goto 10
StackMap locals:
StackMap stack: java.lang.Throwable
8: aload 8
monitorexit
9: athrow
10: StackMap locals:
StackMap stack:
aload 7
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 16
11: aload 2
ifnull 14
12: aload 2
aload 7
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: goto 27
14: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.stomp.impl.StompClientImpl.log:Lio/vertx/core/logging/Logger;
ldc "Unable to connect to the server"
aload 7
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
15: goto 27
16: StackMap locals:
StackMap stack:
new io.vertx.ext.stomp.impl.StompClientConnectionImpl
dup
aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
aload 7
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.net.NetSocket
aload 0
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: aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.receivedFrameHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
18: aload 4
invokeinterface io.vertx.ext.stomp.StompClientConnection.writingFrameHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
19: aload 5
invokeinterface io.vertx.ext.stomp.StompClientConnection.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
20: aload 0
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: astore 8
start local 8 22: aload 0
aload 6
invokevirtual io.vertx.ext.stomp.impl.StompClientImpl.getConnectFrame:(Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
astore 9
start local 9 23: aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.vertx:Lio/vertx/core/Vertx;
aload 0
getfield io.vertx.ext.stomp.impl.StompClientImpl.options:Lio/vertx/ext/stomp/StompClientOptions;
invokevirtual io.vertx.ext.stomp.StompClientOptions.getConnectTimeout:()I
i2l
aload 8
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: aload 4
ifnull 26
25: aload 4
aload 9
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
26: StackMap locals: io.vertx.ext.stomp.StompClientConnection io.vertx.ext.stomp.Frame
StackMap stack:
aload 7
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.net.NetSocket
aload 9
aload 0
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:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/net/NetSocket;
pop
end local 9 end local 8 27: StackMap locals:
StackMap stack:
return
end local 7 end local 0 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 0: aload 0
aload 0
invokevirtual java.lang.StringBuilder.length:()I
ifne 1
aload 1
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
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 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 0: aload 0
ifnull 3
1: aload 0
aload 1
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.stomp.impl.StompClientImpl.log:Lio/vertx/core/logging/Logger;
ldc "Unable to connect to the server"
aload 1
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 1 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 0: aload 0
invokeinterface io.vertx.ext.stomp.StompClientConnection.isConnected:()Z
ifne 3
1: 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: aload 0
invokeinterface io.vertx.ext.stomp.StompClientConnection.close:()V
3: StackMap locals:
StackMap stack:
return
end local 2 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