public class io.vertx.ext.stomp.impl.StompClientConnectionImpl implements io.vertx.ext.stomp.StompClientConnection, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.stomp.impl.StompClientConnectionImpl
super_class: java.lang.Object
{
private static final io.vertx.core.logging.Logger LOGGER;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.ext.stomp.StompClient client;
descriptor: Lio/vertx/ext/stomp/StompClient;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.NetSocket socket;
descriptor: Lio/vertx/core/net/NetSocket;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.stomp.StompClientConnection>> resultHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;
private final io.vertx.core.Context context;
descriptor: Lio/vertx/core/Context;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile long lastServerActivity;
descriptor: J
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final java.util.Map<java.lang.String, io.vertx.core.Handler<java.lang.Void>> pendingReceipts;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/Handler<Ljava/lang/Void;>;>;
private java.lang.String version;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String sessionId;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String server;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private final java.util.List<io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription> subscriptions;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;>;
private volatile long pinger;
descriptor: J
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile long ponger;
descriptor: J
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private io.vertx.core.Handler<io.vertx.ext.stomp.StompClientConnection> pingHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.StompClientConnection> closeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.StompClientConnection> droppedHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
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> writingHandler;
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> errorHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
private volatile boolean closed;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
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 volatile boolean connected;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private static volatile int[] $SWITCH_TABLE$io$vertx$ext$stomp$Frame$Command;
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: ldc Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.ext.stomp.impl.StompClientConnectionImpl.LOGGER:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.Vertx, io.vertx.core.net.NetSocket, io.vertx.ext.stomp.StompClient, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.stomp.StompClientConnection>>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/net/NetSocket;Lio/vertx/ext/stomp/StompClient;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pendingReceipts:Ljava/util/Map;
2: aload 0
new java.util.concurrent.CopyOnWriteArrayList
dup
invokespecial java.util.concurrent.CopyOnWriteArrayList.<init>:()V
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscriptions:Ljava/util/List;
3: aload 0
ldc -1
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pinger:J
4: aload 0
ldc -1
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.ponger:J
5: aload 0
invokedynamic handle()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/StompClientConnectionImpl.lambda$0(Lio/vertx/ext/stomp/StompClientConnection;)V (6)
(Lio/vertx/ext/stomp/StompClientConnection;)V
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pingHandler:Lio/vertx/core/Handler;
6: aload 0
invokedynamic handle()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/StompClientConnectionImpl.lambda$1(Lio/vertx/ext/stomp/StompClientConnection;)V (6)
(Lio/vertx/ext/stomp/StompClientConnection;)V
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.droppedHandler:Lio/vertx/core/Handler;
7: aload 0
aload 2
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.socket:Lio/vertx/core/net/NetSocket;
8: aload 0
aload 3
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
9: aload 0
aload 4
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.resultHandler:Lio/vertx/core/Handler;
10: aload 0
aload 1
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.context:Lio/vertx/core/Context;
11: new io.vertx.ext.stomp.impl.FrameParser
dup
invokespecial io.vertx.ext.stomp.impl.FrameParser.<init>:()V
astore 5
start local 5 12: aload 5
aload 0
invokevirtual io.vertx.ext.stomp.impl.FrameParser.handler:(Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/impl/FrameParser;
pop
13: aload 2
aload 0
aload 5
invokedynamic handle(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;Lio/vertx/ext/stomp/impl/FrameParser;)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/StompClientConnectionImpl.lambda$2(Lio/vertx/ext/stomp/impl/FrameParser;Lio/vertx/core/buffer/Buffer;)V (7)
(Lio/vertx/core/buffer/Buffer;)V
invokeinterface io.vertx.core.net.NetSocket.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
14: aload 0
aload 3
invokedynamic handle(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;Lio/vertx/ext/stomp/StompClient;)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/StompClientConnectionImpl.lambda$3(Lio/vertx/ext/stomp/StompClient;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.net.NetSocket.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
15: return
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 16 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 16 1 vertx Lio/vertx/core/Vertx;
0 16 2 socket Lio/vertx/core/net/NetSocket;
0 16 3 client Lio/vertx/ext/stomp/StompClient;
0 16 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;
12 16 5 parser Lio/vertx/ext/stomp/impl/FrameParser;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/core/net/NetSocket;Lio/vertx/ext/stomp/StompClient;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/stomp/StompClientConnection;>;>;)V
MethodParameters:
Name Flags
vertx
socket
client
resultHandler
public boolean isConnected();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.connected:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
public synchronized java.lang.String session();
descriptor: ()Ljava/lang/String;
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.StompClientConnectionImpl.sessionId:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
public synchronized java.lang.String version();
descriptor: ()Ljava/lang/String;
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.StompClientConnectionImpl.version:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
public synchronized void close();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.closed:Z
1: aload 0
iconst_0
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.connected:Z
2: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.closeHandler:Lio/vertx/core/Handler;
ifnull 4
3: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.context:Lio/vertx/core/Context;
aload 0
invokedynamic handle(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;)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/StompClientConnectionImpl.lambda$4(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pinger:J
ldc -1
lcmp
ifeq 7
5: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.vertx:()Lio/vertx/core/Vertx;
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pinger:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
6: aload 0
ldc -1
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pinger:J
7: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.ponger:J
ldc -1
lcmp
ifeq 10
8: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.vertx:()Lio/vertx/core/Vertx;
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.ponger:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
9: aload 0
ldc -1
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.ponger:J
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.socket:Lio/vertx/core/net/NetSocket;
invokeinterface io.vertx.core.net.NetSocket.close:()V
11: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.close:()V
12: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pendingReceipts:Ljava/util/Map;
invokeinterface java.util.Map.clear:()V
13: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscriptions:Ljava/util/List;
invokeinterface java.util.List.clear:()V
14: aload 0
aconst_null
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.server:Ljava/lang/String;
15: aload 0
aconst_null
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.sessionId:Ljava/lang/String;
16: aload 0
aconst_null
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.version:Ljava/lang/String;
17: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
public synchronized java.lang.String server();
descriptor: ()Ljava/lang/String;
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.StompClientConnectionImpl.server:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
public io.vertx.ext.stomp.StompClientConnection send(java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.buffer.Buffer);
descriptor: (Ljava/util/Map;Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aconst_null
aload 1
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 1 2 body Lio/vertx/core/buffer/Buffer;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
headers
body
public io.vertx.ext.stomp.StompClientConnection send(java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.buffer.Buffer, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/util/Map;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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
aconst_null
aload 1
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 1 2 body Lio/vertx/core/buffer/Buffer;
0 1 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
headers
body
receiptHandler
public io.vertx.ext.stomp.StompClientConnection send(java.lang.String, io.vertx.core.buffer.Buffer);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 body Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
destination
body
public io.vertx.ext.stomp.StompClientConnection send(java.lang.String, io.vertx.core.buffer.Buffer, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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
aload 1
aconst_null
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 body Lio/vertx/core/buffer/Buffer;
0 1 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
destination
body
receiptHandler
public io.vertx.ext.stomp.StompClientConnection send(io.vertx.ext.stomp.Frame);
descriptor: (Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 frame Lio/vertx/ext/stomp/Frame;
MethodParameters:
Name Flags
frame
public synchronized io.vertx.ext.stomp.StompClientConnection send(io.vertx.ext.stomp.Frame, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ifnull 4
1: invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
astore 3
start local 3 2: aload 1
ldc "receipt"
aload 3
invokevirtual io.vertx.ext.stomp.Frame.addHeader:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
pop
3: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pendingReceipts:Ljava/util/Map;
aload 3
aload 2
aload 1
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/ext/stomp/Frame;)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/StompClientConnectionImpl.lambda$5(Lio/vertx/core/Handler;Lio/vertx/ext/stomp/Frame;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 3 4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.writingHandler:Lio/vertx/core/Handler;
ifnull 6
5: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.writingHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.socket:Lio/vertx/core/net/NetSocket;
aload 1
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.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
7: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 8 1 frame Lio/vertx/ext/stomp/Frame;
0 8 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
2 4 3 receiptId Ljava/lang/String;
Signature: (Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
frame
receiptHandler
public io.vertx.ext.stomp.StompClientConnection send(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.buffer.Buffer);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/StompClientConnection;
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
aload 1
aload 2
aload 3
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 1 3 body Lio/vertx/core/buffer/Buffer;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
destination
headers
body
public io.vertx.ext.stomp.StompClientConnection send(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.buffer.Buffer, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 2
ifnonnull 2
1: new io.vertx.ext.stomp.utils.Headers
dup
invokespecial io.vertx.ext.stomp.utils.Headers.<init>:()V
astore 2
2: StackMap locals:
StackMap stack:
aload 1
ifnull 4
3: aload 2
ldc "destination"
aload 1
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: StackMap locals:
StackMap stack:
aload 2
ldc "destination"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
ifnonnull 6
5: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "The 'destination' header is mandatory : "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
aload 3
ifnull 10
7: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.options:()Lio/vertx/ext/stomp/StompClientOptions;
invokevirtual io.vertx.ext.stomp.StompClientOptions.isAutoComputeContentLength:()Z
ifeq 10
8: aload 2
ldc "content-length"
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifne 10
9: aload 2
ldc "content-length"
aload 3
invokeinterface io.vertx.core.buffer.Buffer.length:()I
invokestatic java.lang.Integer.toString:(I)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
10: StackMap locals:
StackMap stack:
new io.vertx.ext.stomp.Frame
dup
getstatic io.vertx.ext.stomp.Frame$Command.SEND:Lio/vertx/ext/stomp/Frame$Command;
aload 2
aload 3
invokespecial io.vertx.ext.stomp.Frame.<init>:(Lio/vertx/ext/stomp/Frame$Command;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;)V
astore 5
start local 5 11: aload 0
aload 5
aload 4
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
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 12 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 12 1 destination Ljava/lang/String;
0 12 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 12 3 body Lio/vertx/core/buffer/Buffer;
0 12 4 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
11 12 5 frame Lio/vertx/ext/stomp/Frame;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
destination
headers
body
receiptHandler
public java.lang.String subscribe(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscribe:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Ljava/lang/String;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Ljava/lang/String;
MethodParameters:
Name Flags
destination
handler
public java.lang.String subscribe(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Ljava/lang/String;
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
aload 1
aconst_null
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscribe:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Ljava/lang/String;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
0 1 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Ljava/lang/String;
MethodParameters:
Name Flags
destination
handler
receiptHandler
public java.lang.String subscribe(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Ljava/lang/String;
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
aload 1
aload 2
aload 3
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscribe:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Ljava/lang/String;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 1 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Ljava/lang/String;
MethodParameters:
Name Flags
destination
headers
handler
public synchronized java.lang.String subscribe(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Ljava/lang/String;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=6, locals=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 3
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
ifnonnull 4
3: invokestatic io.vertx.ext.stomp.utils.Headers.create:()Lio/vertx/ext/stomp/utils/Headers;
astore 2
4: StackMap locals:
StackMap stack:
aload 2
ldc "id"
aload 1
invokeinterface java.util.Map.getOrDefault:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 5
start local 5 5: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
6: aload 5
invokedynamic test(Ljava/lang/String;)Ljava/util/function/Predicate;
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;)Z
io/vertx/ext/stomp/impl/StompClientConnectionImpl.lambda$6(Ljava/lang/String;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z (6)
(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
invokeinterface java.util.stream.Stream.findFirst:()Ljava/util/Optional;
7: astore 6
start local 6 8: aload 6
invokevirtual java.util.Optional.isPresent:()Z
ifeq 10
9: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "The client is already registered to "
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;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
10: StackMap locals: java.lang.String java.util.Optional
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscriptions:Ljava/util/List;
new io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription
dup
aload 1
aload 5
aload 3
invokespecial io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription.<init>:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
11: aload 2
ldc "destination"
aload 1
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
12: aload 2
ldc "id"
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifne 14
13: aload 2
ldc "id"
aload 5
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
14: StackMap locals:
StackMap stack:
new io.vertx.ext.stomp.Frame
dup
getstatic io.vertx.ext.stomp.Frame$Command.SUBSCRIBE:Lio/vertx/ext/stomp/Frame$Command;
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
astore 7
start local 7 15: aload 0
aload 7
aload 4
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
pop
16: aload 5
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 17 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 17 1 destination Ljava/lang/String;
0 17 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 17 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
0 17 4 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
5 17 5 id Ljava/lang/String;
8 17 6 maybeSubscription Ljava/util/Optional<Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;>;
15 17 7 frame Lio/vertx/ext/stomp/Frame;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Ljava/lang/String;
MethodParameters:
Name Flags
destination
headers
handler
receiptHandler
public io.vertx.ext.stomp.StompClientConnection unsubscribe(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.unsubscribe:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
MethodParameters:
Name Flags
destination
public io.vertx.ext.stomp.StompClientConnection unsubscribe(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.unsubscribe:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
destination
receiptHandler
public io.vertx.ext.stomp.StompClientConnection unsubscribe(java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Map;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.unsubscribe:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 destination Ljava/lang/String;
0 1 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
destination
headers
public synchronized io.vertx.ext.stomp.StompClientConnection unsubscribe(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=6, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 2
ifnonnull 3
2: invokestatic io.vertx.ext.stomp.utils.Headers.create:()Lio/vertx/ext/stomp/utils/Headers;
astore 2
3: StackMap locals:
StackMap stack:
aload 2
ldc "id"
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 4
aload 2
ldc "id"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
goto 5
StackMap locals:
StackMap stack:
4: aload 1
StackMap locals:
StackMap stack: java.lang.String
5: astore 4
start local 4 6: aload 2
ldc "id"
aload 4
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
8: aload 4
invokedynamic test(Ljava/lang/String;)Ljava/util/function/Predicate;
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;)Z
io/vertx/ext/stomp/impl/StompClientConnectionImpl.lambda$7(Ljava/lang/String;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z (6)
(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
invokeinterface java.util.stream.Stream.findFirst:()Ljava/util/Optional;
9: astore 5
start local 5 10: aload 5
invokevirtual java.util.Optional.isPresent:()Z
ifeq 15
11: aload 5
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription
astore 6
start local 6 12: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscriptions:Ljava/util/List;
aload 6
invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
pop
13: aload 0
new io.vertx.ext.stomp.Frame
dup
getstatic io.vertx.ext.stomp.Frame$Command.UNSUBSCRIBE:Lio/vertx/ext/stomp/Frame$Command;
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
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
pop
14: aload 0
areturn
end local 6 15: StackMap locals: java.lang.String java.util.Optional
StackMap stack:
new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "No subscription with id "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
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 16 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 16 1 destination Ljava/lang/String;
0 16 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 16 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
6 16 4 id Ljava/lang/String;
10 16 5 maybeSubscription Ljava/util/Optional<Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;>;
12 15 6 subscription Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
destination
headers
receiptHandler
public synchronized io.vertx.ext.stomp.StompClientConnection errorHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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.StompClientConnectionImpl.errorHandler: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/StompClientConnectionImpl;
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/StompClientConnection;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompClientConnection closeHandler(io.vertx.core.Handler<io.vertx.ext.stomp.StompClientConnection>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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.StompClientConnectionImpl.closeHandler: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/StompClientConnectionImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompClientConnection pingHandler(io.vertx.core.Handler<io.vertx.ext.stomp.StompClientConnection>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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.StompClientConnectionImpl.pingHandler: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/StompClientConnectionImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
handler
public io.vertx.ext.stomp.StompClientConnection beginTX(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
new io.vertx.ext.stomp.utils.Headers
dup
invokespecial io.vertx.ext.stomp.utils.Headers.<init>:()V
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.beginTX:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
receiptHandler
public io.vertx.ext.stomp.StompClientConnection beginTX(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
new io.vertx.ext.stomp.utils.Headers
dup
invokespecial io.vertx.ext.stomp.utils.Headers.<init>:()V
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.beginTX:(Ljava/lang/String;Ljava/util/Map;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
MethodParameters:
Name Flags
id
public io.vertx.ext.stomp.StompClientConnection beginTX(java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Map;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.beginTX:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
headers
public io.vertx.ext.stomp.StompClientConnection beginTX(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 2
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 0
new io.vertx.ext.stomp.Frame
dup
invokespecial io.vertx.ext.stomp.Frame.<init>:()V
getstatic io.vertx.ext.stomp.Frame$Command.BEGIN:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame.setCommand:(Lio/vertx/ext/stomp/Frame$Command;)Lio/vertx/ext/stomp/Frame;
aload 1
invokevirtual io.vertx.ext.stomp.Frame.setTransaction:(Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 3 1 id Ljava/lang/String;
0 3 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 3 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
headers
receiptHandler
public io.vertx.ext.stomp.StompClientConnection commit(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
new io.vertx.ext.stomp.utils.Headers
dup
invokespecial io.vertx.ext.stomp.utils.Headers.<init>:()V
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.commit:(Ljava/lang/String;Ljava/util/Map;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
MethodParameters:
Name Flags
id
public io.vertx.ext.stomp.StompClientConnection commit(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
new io.vertx.ext.stomp.utils.Headers
dup
invokespecial io.vertx.ext.stomp.utils.Headers.<init>:()V
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.commit:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
receiptHandler
public io.vertx.ext.stomp.StompClientConnection commit(java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Map;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.commit:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
headers
public io.vertx.ext.stomp.StompClientConnection commit(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 2
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 0
new io.vertx.ext.stomp.Frame
dup
invokespecial io.vertx.ext.stomp.Frame.<init>:()V
getstatic io.vertx.ext.stomp.Frame$Command.COMMIT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame.setCommand:(Lio/vertx/ext/stomp/Frame$Command;)Lio/vertx/ext/stomp/Frame;
aload 1
invokevirtual io.vertx.ext.stomp.Frame.setTransaction:(Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 3 1 id Ljava/lang/String;
0 3 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 3 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
headers
receiptHandler
public io.vertx.ext.stomp.StompClientConnection abort(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
new io.vertx.ext.stomp.utils.Headers
dup
invokespecial io.vertx.ext.stomp.utils.Headers.<init>:()V
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.abort:(Ljava/lang/String;Ljava/util/Map;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
MethodParameters:
Name Flags
id
public io.vertx.ext.stomp.StompClientConnection abort(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
new io.vertx.ext.stomp.utils.Headers
dup
invokespecial io.vertx.ext.stomp.utils.Headers.<init>:()V
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.abort:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
receiptHandler
public io.vertx.ext.stomp.StompClientConnection abort(java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Map;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.abort:(Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
headers
public io.vertx.ext.stomp.StompClientConnection abort(java.lang.String, java.util.Map<java.lang.String, java.lang.String>, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 2
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 0
new io.vertx.ext.stomp.Frame
dup
invokespecial io.vertx.ext.stomp.Frame.<init>:()V
getstatic io.vertx.ext.stomp.Frame$Command.ABORT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame.setCommand:(Lio/vertx/ext/stomp/Frame$Command;)Lio/vertx/ext/stomp/Frame;
aload 1
invokevirtual io.vertx.ext.stomp.Frame.setTransaction:(Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 3 1 id Ljava/lang/String;
0 3 2 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 3 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
headers
receiptHandler
public io.vertx.ext.stomp.StompClientConnection disconnect();
descriptor: ()Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
new io.vertx.ext.stomp.Frame
dup
invokespecial io.vertx.ext.stomp.Frame.<init>:()V
getstatic io.vertx.ext.stomp.Frame$Command.DISCONNECT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame.setCommand:(Lio/vertx/ext/stomp/Frame$Command;)Lio/vertx/ext/stomp/Frame;
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.disconnect:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
public io.vertx.ext.stomp.StompClientConnection disconnect(io.vertx.ext.stomp.Frame);
descriptor: (Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.disconnect:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 frame Lio/vertx/ext/stomp/Frame;
MethodParameters:
Name Flags
frame
public io.vertx.ext.stomp.StompClientConnection disconnect(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new io.vertx.ext.stomp.Frame
dup
invokespecial io.vertx.ext.stomp.Frame.<init>:()V
getstatic io.vertx.ext.stomp.Frame$Command.DISCONNECT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame.setCommand:(Lio/vertx/ext/stomp/Frame$Command;)Lio/vertx/ext/stomp/Frame;
aload 1
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.disconnect:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
receiptHandler
public io.vertx.ext.stomp.StompClientConnection disconnect(io.vertx.ext.stomp.Frame, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
aload 1
aload 0
aload 2
invokedynamic handle(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;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/StompClientConnectionImpl.lambda$8(Lio/vertx/core/Handler;Lio/vertx/ext/stomp/Frame;)V (7)
(Lio/vertx/ext/stomp/Frame;)V
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
pop
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 3 1 frame Lio/vertx/ext/stomp/Frame;
0 3 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
frame
receiptHandler
public io.vertx.ext.stomp.StompClientConnection ack(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.ack:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
MethodParameters:
Name Flags
id
public io.vertx.ext.stomp.StompClientConnection ack(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
new io.vertx.ext.stomp.Frame
dup
getstatic io.vertx.ext.stomp.Frame$Command.ACK:Lio/vertx/ext/stomp/Frame$Command;
iconst_2
anewarray java.lang.String
dup
iconst_0
ldc "id"
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.vertx.ext.stomp.utils.Headers.create:([Ljava/lang/String;)Lio/vertx/ext/stomp/utils/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
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
pop
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 3 1 id Ljava/lang/String;
0 3 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
receiptHandler
public io.vertx.ext.stomp.StompClientConnection nack(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.nack:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
MethodParameters:
Name Flags
id
public io.vertx.ext.stomp.StompClientConnection nack(java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
new io.vertx.ext.stomp.Frame
dup
getstatic io.vertx.ext.stomp.Frame$Command.NACK:Lio/vertx/ext/stomp/Frame$Command;
iconst_2
anewarray java.lang.String
dup
iconst_0
ldc "id"
aastore
dup
iconst_1
aload 1
aastore
invokestatic io.vertx.ext.stomp.utils.Headers.create:([Ljava/lang/String;)Lio/vertx/ext/stomp/utils/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
aload 2
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
pop
2: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 3 1 id Ljava/lang/String;
0 3 2 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
receiptHandler
public io.vertx.ext.stomp.StompClientConnection ack(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.ack:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 txId Ljava/lang/String;
MethodParameters:
Name Flags
id
txId
public io.vertx.ext.stomp.StompClientConnection ack(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "A ACK frame must contain the ACK id"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 0
new io.vertx.ext.stomp.Frame
dup
getstatic io.vertx.ext.stomp.Frame$Command.ACK:Lio/vertx/ext/stomp/Frame$Command;
iconst_4
anewarray java.lang.String
dup
iconst_0
ldc "id"
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
ldc "transaction"
aastore
dup
iconst_3
aload 2
aastore
invokestatic io.vertx.ext.stomp.utils.Headers.create:([Ljava/lang/String;)Lio/vertx/ext/stomp/utils/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
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
pop
3: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 4 1 id Ljava/lang/String;
0 4 2 txId Ljava/lang/String;
0 4 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
txId
receiptHandler
public io.vertx.ext.stomp.StompClientConnection nack(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.nack:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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/StompClientConnectionImpl;
0 1 1 id Ljava/lang/String;
0 1 2 txId Ljava/lang/String;
MethodParameters:
Name Flags
id
txId
public io.vertx.ext.stomp.StompClientConnection nack(java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "A NACK frame must contain the ACK id"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 2
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: new io.vertx.ext.stomp.Frame
dup
getstatic io.vertx.ext.stomp.Frame$Command.NACK:Lio/vertx/ext/stomp/Frame$Command;
iconst_4
anewarray java.lang.String
dup
iconst_0
ldc "id"
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
ldc "transaction"
aastore
dup
iconst_3
aload 2
aastore
invokestatic io.vertx.ext.stomp.utils.Headers.create:([Ljava/lang/String;)Lio/vertx/ext/stomp/utils/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
astore 4
start local 4 3: aload 0
aload 4
aload 3
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.send:(Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
pop
4: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 5 1 id Ljava/lang/String;
0 5 2 txId Ljava/lang/String;
0 5 3 receiptHandler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
3 5 4 toSend Lio/vertx/ext/stomp/Frame;
Signature: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
id
txId
receiptHandler
public synchronized io.vertx.ext.stomp.StompClientConnection receivedFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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.StompClientConnectionImpl.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/StompClientConnectionImpl;
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/StompClientConnection;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompClientConnection writingFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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.StompClientConnectionImpl.writingHandler: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/StompClientConnectionImpl;
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/StompClientConnection;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompClientConnection exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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.StompClientConnectionImpl.exceptionHandler:Lio/vertx/core/Handler;
1: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.connected:Z
ifeq 3
2: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.socket:Lio/vertx/core/net/NetSocket;
aload 1
invokeinterface io.vertx.core.net.NetSocket.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
3: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 4 1 exceptionHandler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
exceptionHandler
public synchronized io.vertx.ext.stomp.StompClientConnection connectionDroppedHandler(io.vertx.core.Handler<io.vertx.ext.stomp.StompClientConnection>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompClientConnection;
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.StompClientConnectionImpl.droppedHandler: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/StompClientConnectionImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;)Lio/vertx/ext/stomp/StompClientConnection;
MethodParameters:
Name Flags
handler
public void handle(io.vertx.ext.stomp.Frame);
descriptor: (Lio/vertx/ext/stomp/Frame;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.receivedFrameHandler:Lio/vertx/core/Handler;
ifnull 3
2: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.receivedFrameHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals: io.vertx.ext.stomp.impl.StompClientConnectionImpl
StackMap stack:
aload 2
monitorexit
4: goto 7
StackMap locals:
StackMap stack: java.lang.Throwable
5: aload 2
monitorexit
6: athrow
7: StackMap locals:
StackMap stack:
invokestatic io.vertx.ext.stomp.impl.StompClientConnectionImpl.$SWITCH_TABLE$io$vertx$ext$stomp$Frame$Command:()[I
aload 1
invokevirtual io.vertx.ext.stomp.Frame.getCommand:()Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
iaload
lookupswitch { // 5
2: 8
13: 12
14: 10
15: 16
16: 19
default: 19
}
8: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.handleConnected:(Lio/vertx/ext/stomp/Frame;)V
9: goto 19
10: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.handleReceipt:(Lio/vertx/ext/stomp/Frame;)V
11: goto 19
12: StackMap locals:
StackMap stack:
aload 1
ldc "subscription"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
astore 2
start local 2 13: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
14: aload 2
invokedynamic test(Ljava/lang/String;)Ljava/util/function/Predicate;
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;)Z
io/vertx/ext/stomp/impl/StompClientConnectionImpl.lambda$9(Ljava/lang/String;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z (6)
(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
aload 1
invokedynamic accept(Lio/vertx/ext/stomp/Frame;)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/StompClientConnectionImpl.lambda$10(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)V (6)
(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
15: goto 19
end local 2 16: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.errorHandler:Lio/vertx/core/Handler;
ifnull 19
17: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.errorHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
18: goto 19
19: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 20 1 frame Lio/vertx/ext/stomp/Frame;
13 16 2 id Ljava/lang/String;
Exception table:
from to target type
1 4 5 any
5 6 5 any
MethodParameters:
Name Flags
frame
private synchronized void handleReceipt(io.vertx.ext.stomp.Frame);
descriptor: (Lio/vertx/ext/stomp/Frame;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 1
ldc "receipt-id"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
astore 2
start local 2 1: aload 2
ifnull 6
2: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pendingReceipts:Ljava/util/Map;
aload 2
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.Handler
astore 3
start local 3 3: aload 3
ifnonnull 5
4: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "No receipt handler for receipt "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
5: StackMap locals: java.lang.String io.vertx.core.Handler
StackMap stack:
aload 3
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 3 6: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 7 1 frame Lio/vertx/ext/stomp/Frame;
1 7 2 receipt Ljava/lang/String;
3 6 3 receiptHandler Lio/vertx/core/Handler<Ljava/lang/Void;>;
MethodParameters:
Name Flags
frame
private synchronized void handleConnected(io.vertx.ext.stomp.Frame);
descriptor: (Lio/vertx/ext/stomp/Frame;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=7, locals=6, args_size=2
start local 0 start local 1 0: aload 0
aload 1
ldc "session"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.sessionId:Ljava/lang/String;
1: aload 0
aload 1
ldc "version"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.version:Ljava/lang/String;
2: aload 0
aload 1
ldc "server"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.server:Ljava/lang/String;
3: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.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;
4: aload 1
ldc "heart-beat"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
invokestatic io.vertx.ext.stomp.Frame$Heartbeat.parse:(Ljava/lang/String;)Lio/vertx/ext/stomp/Frame$Heartbeat;
5: invokestatic io.vertx.ext.stomp.Frame$Heartbeat.computePingPeriod:(Lio/vertx/ext/stomp/Frame$Heartbeat;Lio/vertx/ext/stomp/Frame$Heartbeat;)J
lstore 2
start local 2 6: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.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;
7: aload 1
ldc "heart-beat"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
invokestatic io.vertx.ext.stomp.Frame$Heartbeat.parse:(Ljava/lang/String;)Lio/vertx/ext/stomp/Frame$Heartbeat;
8: invokestatic io.vertx.ext.stomp.Frame$Heartbeat.computePongPeriod:(Lio/vertx/ext/stomp/Frame$Heartbeat;Lio/vertx/ext/stomp/Frame$Heartbeat;)J
lstore 4
start local 4 9: lload 2
lconst_0
lcmp
ifle 11
10: aload 0
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.vertx:()Lio/vertx/core/Vertx;
lload 2
aload 0
invokedynamic handle(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;)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/StompClientConnectionImpl.lambda$11(Ljava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Vertx.setPeriodic:(JLio/vertx/core/Handler;)J
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pinger:J
11: StackMap locals: long long
StackMap stack:
lload 4
lconst_0
lcmp
ifle 13
12: aload 0
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.vertx:()Lio/vertx/core/Vertx;
lload 4
aload 0
lload 4
invokedynamic handle(Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;J)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/StompClientConnectionImpl.lambda$12(JLjava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Vertx.setPeriodic:(JLio/vertx/core/Handler;)J
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.ponger:J
13: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.socket:Lio/vertx/core/net/NetSocket;
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.exceptionHandler:Lio/vertx/core/Handler;
invokeinterface io.vertx.core.net.NetSocket.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
14: aload 0
iconst_1
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.connected:Z
15: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.resultHandler:Lio/vertx/core/Handler;
aload 0
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
16: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 17 1 frame Lio/vertx/ext/stomp/Frame;
6 17 2 ping J
9 17 4 pong J
MethodParameters:
Name Flags
frame
public io.vertx.core.net.NetSocket socket();
descriptor: ()Lio/vertx/core/net/NetSocket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.socket:Lio/vertx/core/net/NetSocket;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
public void handle(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.ext.stomp.Frame
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.handle:(Lio/vertx/ext/stomp/Frame;)V
return
LocalVariableTable:
Start End Slot Name Signature
static int[] $SWITCH_TABLE$io$vertx$ext$stomp$Frame$Command();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic io.vertx.ext.stomp.impl.StompClientConnectionImpl.$SWITCH_TABLE$io$vertx$ext$stomp$Frame$Command:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic io.vertx.ext.stomp.Frame$Command.values:()[Lio/vertx/ext/stomp/Frame$Command;
arraylength
newarray 10
astore 0
2: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.ABORT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 11
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.ACK:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 7
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.BEGIN:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 9
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.COMMIT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 10
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.CONNECT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
iconst_1
iastore
15: goto 17
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
16: pop
StackMap locals:
StackMap stack:
17: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.CONNECTED:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
iconst_2
iastore
18: goto 20
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
19: pop
StackMap locals:
StackMap stack:
20: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.DISCONNECT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 12
iastore
21: goto 23
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
22: pop
StackMap locals:
StackMap stack:
23: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.ERROR:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 15
iastore
24: goto 26
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
25: pop
StackMap locals:
StackMap stack:
26: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.MESSAGE:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 13
iastore
27: goto 29
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
28: pop
StackMap locals:
StackMap stack:
29: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.NACK:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 8
iastore
30: goto 32
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
31: pop
StackMap locals:
StackMap stack:
32: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.PING:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 16
iastore
33: goto 35
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
34: pop
StackMap locals:
StackMap stack:
35: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.RECEIPT:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 14
iastore
36: goto 38
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
37: pop
StackMap locals:
StackMap stack:
38: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.SEND:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
iconst_4
iastore
39: goto 41
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
40: pop
StackMap locals:
StackMap stack:
41: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.STOMP:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
iconst_3
iastore
42: goto 44
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
43: pop
StackMap locals:
StackMap stack:
44: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.SUBSCRIBE:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
iconst_5
iastore
45: goto 47
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
46: pop
StackMap locals:
StackMap stack:
47: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.UNKNOWN:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 17
iastore
48: goto 50
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
49: pop
StackMap locals:
StackMap stack:
50: aload 0
getstatic io.vertx.ext.stomp.Frame$Command.UNSUBSCRIBE:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
bipush 6
iastore
51: goto 53
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
52: pop
StackMap locals:
StackMap stack:
53: aload 0
dup
putstatic io.vertx.ext.stomp.impl.StompClientConnectionImpl.$SWITCH_TABLE$io$vertx$ext$stomp$Frame$Command:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
8 9 10 Class java.lang.NoSuchFieldError
11 12 13 Class java.lang.NoSuchFieldError
14 15 16 Class java.lang.NoSuchFieldError
17 18 19 Class java.lang.NoSuchFieldError
20 21 22 Class java.lang.NoSuchFieldError
23 24 25 Class java.lang.NoSuchFieldError
26 27 28 Class java.lang.NoSuchFieldError
29 30 31 Class java.lang.NoSuchFieldError
32 33 34 Class java.lang.NoSuchFieldError
35 36 37 Class java.lang.NoSuchFieldError
38 39 40 Class java.lang.NoSuchFieldError
41 42 43 Class java.lang.NoSuchFieldError
44 45 46 Class java.lang.NoSuchFieldError
47 48 49 Class java.lang.NoSuchFieldError
50 51 52 Class java.lang.NoSuchFieldError
private static void lambda$0(io.vertx.ext.stomp.StompClientConnection);
descriptor: (Lio/vertx/ext/stomp/StompClientConnection;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic io.vertx.ext.stomp.Frames.ping:()Lio/vertx/ext/stomp/Frame;
invokeinterface io.vertx.ext.stomp.StompClientConnection.send:(Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompClientConnection;
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 connection Lio/vertx/ext/stomp/StompClientConnection;
private static void lambda$1(io.vertx.ext.stomp.StompClientConnection);
descriptor: (Lio/vertx/ext/stomp/StompClientConnection;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Lio/vertx/ext/stomp/StompClientConnection;
private void lambda$2(io.vertx.ext.stomp.impl.FrameParser, io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/ext/stomp/impl/FrameParser;Lio/vertx/core/buffer/Buffer;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
invokestatic java.lang.System.nanoTime:()J
putfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.lastServerActivity:J
1: aload 1
aload 2
invokevirtual io.vertx.ext.stomp.impl.FrameParser.handle:(Lio/vertx/core/buffer/Buffer;)V
2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 3 2 buffer Lio/vertx/core/buffer/Buffer;
private void lambda$3(io.vertx.ext.stomp.StompClient, java.lang.Void);
descriptor: (Lio/vertx/ext/stomp/StompClient;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.closed:Z
ifne 4
aload 1
invokeinterface io.vertx.ext.stomp.StompClient.isClosed:()Z
ifne 4
1: aload 0
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.close:()V
2: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.droppedHandler:Lio/vertx/core/Handler;
ifnull 4
3: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.droppedHandler:Lio/vertx/core/Handler;
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 5 2 v Ljava/lang/Void;
private void lambda$4(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.closeHandler:Lio/vertx/core/Handler;
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 v Ljava/lang/Void;
private static void lambda$5(io.vertx.core.Handler, io.vertx.ext.stomp.Frame, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/ext/stomp/Frame;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 f Ljava/lang/Void;
private static boolean lambda$6(java.lang.String, io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription);
descriptor: (Ljava/lang/String;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription.id:Ljava/lang/String;
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;
private static boolean lambda$7(java.lang.String, io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription);
descriptor: (Ljava/lang/String;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription.id:Ljava/lang/String;
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;
private void lambda$8(io.vertx.core.Handler, io.vertx.ext.stomp.Frame);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/ext/stomp/Frame;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 1
ifnull 2
1: aload 1
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.closed:Z
ifne 4
3: aload 0
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.close:()V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 5 2 f Lio/vertx/ext/stomp/Frame;
private static boolean lambda$9(java.lang.String, io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription);
descriptor: (Ljava/lang/String;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription.id:Ljava/lang/String;
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;
private static void lambda$10(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription.handler:Lio/vertx/core/Handler;
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lio/vertx/ext/stomp/impl/StompClientConnectionImpl$Subscription;
private void lambda$11(java.lang.Long);
descriptor: (Ljava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.pingHandler:Lio/vertx/core/Handler;
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 1 1 l Ljava/lang/Long;
private void lambda$12(long, java.lang.Long);
descriptor: (JLjava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=10, args_size=3
start local 0 start local 3 0: invokestatic java.lang.System.nanoTime:()J
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.lastServerActivity:J
lsub
lstore 4
start local 4 1: getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
lload 4
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual java.util.concurrent.TimeUnit.convert:(JLjava/util/concurrent/TimeUnit;)J
lstore 6
start local 6 2: lload 6
lload 1
ldc 2
lmul
lcmp
ifle 14
3: getstatic io.vertx.ext.stomp.impl.StompClientConnectionImpl.LOGGER:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Disconnecting client "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " - no server activity detected in the last "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
lload 6
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " ms."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;)V
4: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.client:Lio/vertx/ext/stomp/StompClient;
invokeinterface io.vertx.ext.stomp.StompClient.vertx:()Lio/vertx/core/Vertx;
aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.ponger:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
5: aload 0
invokevirtual io.vertx.ext.stomp.impl.StompClientConnectionImpl.close:()V
6: aload 0
dup
astore 9
monitorenter
7: aload 0
getfield io.vertx.ext.stomp.impl.StompClientConnectionImpl.droppedHandler:Lio/vertx/core/Handler;
astore 8
start local 8 8: aload 9
monitorexit
9: goto 12
end local 8 StackMap locals: io.vertx.ext.stomp.impl.StompClientConnectionImpl long java.lang.Long long long top io.vertx.ext.stomp.impl.StompClientConnectionImpl
StackMap stack: java.lang.Throwable
10: aload 9
monitorexit
11: athrow
start local 8 12: StackMap locals: io.vertx.ext.stomp.impl.StompClientConnectionImpl long java.lang.Long long long io.vertx.core.Handler
StackMap stack:
aload 8
ifnull 14
13: aload 8
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 8 end local 6 end local 4 14: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/ext/stomp/impl/StompClientConnectionImpl;
0 15 3 l Ljava/lang/Long;
1 14 4 delta J
2 14 6 deltaInMs J
8 10 8 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
12 14 8 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompClientConnection;>;
Exception table:
from to target type
7 9 10 any
10 11 10 any
}
Signature: Ljava/lang/Object;Lio/vertx/ext/stomp/StompClientConnection;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Frame;>;
SourceFile: "StompClientConnectionImpl.java"
NestMembers:
io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription
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
private Subscription = io.vertx.ext.stomp.impl.StompClientConnectionImpl$Subscription of io.vertx.ext.stomp.impl.StompClientConnectionImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles