public class io.vertx.ext.stomp.impl.DefaultStompHandler implements io.vertx.ext.stomp.StompServerHandler
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.stomp.impl.DefaultStompHandler
super_class: java.lang.Object
{
private static final io.vertx.core.impl.logging.Logger LOGGER;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.Context context;
descriptor: Lio/vertx/core/Context;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> connectHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> stompHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> sendHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> subscribeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> unsubscribeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.StompServerConnection> closeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> commitHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> abortHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> beginHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> ackHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> nackHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> disconnectHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
private io.vertx.ext.auth.authentication.AuthenticationProvider authProvider;
descriptor: Lio/vertx/ext/auth/authentication/AuthenticationProvider;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<io.vertx.ext.stomp.StompServerConnection> pingHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.Acknowledgement> onAckHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
private io.vertx.core.Handler<io.vertx.ext.stomp.Acknowledgement> onNackHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
private final io.vertx.core.shareddata.LocalMap<io.vertx.ext.stomp.Destination, java.lang.String> destinations;
descriptor: Lio/vertx/core/shareddata/LocalMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/shareddata/LocalMap<Lio/vertx/ext/stomp/Destination;Ljava/lang/String;>;
private final java.util.concurrent.ConcurrentHashMap<java.lang.String, io.vertx.ext.auth.User> users;
descriptor: Ljava/util/concurrent/ConcurrentHashMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentHashMap<Ljava/lang/String;Lio/vertx/ext/auth/User;>;
private io.vertx.ext.stomp.DestinationFactory factory;
descriptor: Lio/vertx/ext/stomp/DestinationFactory;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame> receivedFrameHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
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/DefaultStompHandler;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.ext.stomp.impl.DefaultStompHandler.LOGGER:Lio/vertx/core/impl/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new io.vertx.ext.stomp.DefaultConnectHandler
dup
invokespecial io.vertx.ext.stomp.DefaultConnectHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.connectHandler:Lio/vertx/core/Handler;
2: aload 0
new io.vertx.ext.stomp.DefaultSendHandler
dup
invokespecial io.vertx.ext.stomp.DefaultSendHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.sendHandler:Lio/vertx/core/Handler;
3: aload 0
new io.vertx.ext.stomp.DefaultSubscribeHandler
dup
invokespecial io.vertx.ext.stomp.DefaultSubscribeHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.subscribeHandler:Lio/vertx/core/Handler;
4: aload 0
new io.vertx.ext.stomp.DefaultUnsubscribeHandler
dup
invokespecial io.vertx.ext.stomp.DefaultUnsubscribeHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.unsubscribeHandler:Lio/vertx/core/Handler;
5: aload 0
new io.vertx.ext.stomp.DefaultCommitHandler
dup
invokespecial io.vertx.ext.stomp.DefaultCommitHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.commitHandler:Lio/vertx/core/Handler;
6: aload 0
new io.vertx.ext.stomp.DefaultAbortHandler
dup
invokespecial io.vertx.ext.stomp.DefaultAbortHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.abortHandler:Lio/vertx/core/Handler;
7: aload 0
new io.vertx.ext.stomp.DefaultBeginHandler
dup
invokespecial io.vertx.ext.stomp.DefaultBeginHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.beginHandler:Lio/vertx/core/Handler;
8: aload 0
new io.vertx.ext.stomp.DefaultAckHandler
dup
invokespecial io.vertx.ext.stomp.DefaultAckHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.ackHandler:Lio/vertx/core/Handler;
9: aload 0
new io.vertx.ext.stomp.DefaultNackHandler
dup
invokespecial io.vertx.ext.stomp.DefaultNackHandler.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.nackHandler:Lio/vertx/core/Handler;
10: 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/DefaultStompHandler.lambda$0(Lio/vertx/ext/stomp/ServerFrame;)V (6)
(Lio/vertx/ext/stomp/ServerFrame;)V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.disconnectHandler:Lio/vertx/core/Handler;
11: 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/StompServerConnection.ping()V (9 itf)
(Lio/vertx/ext/stomp/StompServerConnection;)V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.pingHandler:Lio/vertx/core/Handler;
12: 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/DefaultStompHandler.lambda$2(Lio/vertx/ext/stomp/Acknowledgement;)V (6)
(Lio/vertx/ext/stomp/Acknowledgement;)V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.onAckHandler:Lio/vertx/core/Handler;
13: 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/DefaultStompHandler.lambda$3(Lio/vertx/ext/stomp/Acknowledgement;)V (6)
(Lio/vertx/ext/stomp/Acknowledgement;)V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.onNackHandler:Lio/vertx/core/Handler;
14: aload 0
invokedynamic create()Lio/vertx/ext/stomp/DestinationFactory;
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:
(Lio/vertx/core/Vertx;Ljava/lang/String;)Lio/vertx/ext/stomp/Destination;
io/vertx/ext/stomp/Destination.topic(Lio/vertx/core/Vertx;Ljava/lang/String;)Lio/vertx/ext/stomp/Destination; (6 itf)
(Lio/vertx/core/Vertx;Ljava/lang/String;)Lio/vertx/ext/stomp/Destination;
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.factory:Lio/vertx/ext/stomp/DestinationFactory;
15: aload 0
aload 1
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.vertx:Lio/vertx/core/Vertx;
16: aload 0
invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.context:Lio/vertx/core/Context;
17: aload 0
aload 1
invokeinterface io.vertx.core.Vertx.sharedData:()Lio/vertx/core/shareddata/SharedData;
ldc "stomp.destinations"
invokeinterface io.vertx.core.shareddata.SharedData.getLocalMap:(Ljava/lang/String;)Lio/vertx/core/shareddata/LocalMap;
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.destinations:Lio/vertx/core/shareddata/LocalMap;
18: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.vertx.ext.stomp.impl.DefaultStompHandler.users:Ljava/util/concurrent/ConcurrentHashMap;
19: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 20 1 vertx Lio/vertx/core/Vertx;
MethodParameters:
Name Flags
vertx
public synchronized void onClose(io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.getDestinations:()Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 1
invokedynamic accept(Lio/vertx/ext/stomp/StompServerConnection;)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/DefaultStompHandler.lambda$5(Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Destination;)V (6)
(Lio/vertx/ext/stomp/Destination;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
1: invokestatic io.vertx.ext.stomp.impl.Transactions.instance:()Lio/vertx/ext/stomp/impl/Transactions;
aload 1
invokevirtual io.vertx.ext.stomp.impl.Transactions.unregisterTransactionsFromConnection:(Lio/vertx/ext/stomp/StompServerConnection;)V
2: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.users:Ljava/util/concurrent/ConcurrentHashMap;
aload 1
invokeinterface io.vertx.ext.stomp.StompServerConnection.session:()Ljava/lang/String;
invokevirtual java.util.concurrent.ConcurrentHashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.closeHandler:Lio/vertx/core/Handler;
ifnull 5
4: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.closeHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 6 1 connection Lio/vertx/ext/stomp/StompServerConnection;
MethodParameters:
Name Flags
connection
public synchronized io.vertx.ext.stomp.StompServerHandler receivedFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler connectHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.connectHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler stompHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.stompHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler subscribeHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.subscribeHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler unsubscribeHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.unsubscribeHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler sendHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.sendHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler closeHandler(io.vertx.core.Handler<io.vertx.ext.stomp.StompServerConnection>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler commitHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.commitHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler abortHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.abortHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler beginHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.beginHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler disconnectHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.disconnectHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler ackHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.ackHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler nackHandler(io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.nackHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public void handle(io.vertx.ext.stomp.ServerFrame);
descriptor: (Lio/vertx/ext/stomp/ServerFrame;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.ext.stomp.ServerFrame.frame:()Lio/vertx/ext/stomp/Frame;
astore 2
start local 2 1: aload 1
invokeinterface io.vertx.ext.stomp.ServerFrame.connection:()Lio/vertx/ext/stomp/StompServerConnection;
astore 3
start local 3 2: aload 3
invokeinterface io.vertx.ext.stomp.StompServerConnection.onServerActivity:()V
3: aload 0
dup
astore 4
monitorenter
4: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.receivedFrameHandler:Lio/vertx/core/Handler;
ifnull 6
5: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.receivedFrameHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals: io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack:
aload 4
monitorexit
7: goto 10
StackMap locals:
StackMap stack: java.lang.Throwable
8: aload 4
monitorexit
9: athrow
10: StackMap locals:
StackMap stack:
invokestatic io.vertx.ext.stomp.impl.DefaultStompHandler.$SWITCH_TABLE$io$vertx$ext$stomp$Frame$Command:()[I
aload 2
invokevirtual io.vertx.ext.stomp.Frame.getCommand:()Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame$Command.ordinal:()I
iaload
tableswitch { // 1 - 16
1: 11
2: 34
3: 13
4: 15
5: 17
6: 19
7: 27
8: 29
9: 21
10: 25
11: 23
12: 31
13: 34
14: 34
15: 34
16: 33
default: 34
}
11: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleConnect:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
12: goto 34
13: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleStomp:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
14: goto 34
15: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleSend:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
16: goto 34
17: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleSubscribe:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
18: goto 34
19: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleUnsubscribe:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
20: goto 34
21: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleBegin:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
22: goto 34
23: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleAbort:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
24: goto 34
25: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleCommit:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
26: goto 34
27: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleAck:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
28: goto 34
29: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleNack:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
30: goto 34
31: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 3
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleDisconnect:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
32: goto 34
33: StackMap locals:
StackMap stack:
goto 34
34: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 35 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 35 1 serverFrame Lio/vertx/ext/stomp/ServerFrame;
1 35 2 frame Lio/vertx/ext/stomp/Frame;
2 35 3 connection Lio/vertx/ext/stomp/StompServerConnection;
Exception table:
from to target type
4 7 8 any
8 9 8 any
MethodParameters:
Name Flags
serverFrame
private void handleAck(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.ackHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleNack(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.nackHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleBegin(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.beginHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleAbort(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.abortHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleCommit(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.commitHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleSubscribe(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.subscribeHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleUnsubscribe(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.unsubscribeHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleSend(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.sendHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleConnect(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=9, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 5
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.connectHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.pingHandler:Lio/vertx/core/Handler;
astore 4
start local 4 3: aload 5
monitorexit
4: goto 7
end local 4 end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
5: aload 5
monitorexit
6: athrow
start local 3 start local 4 7: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler io.vertx.core.Handler
StackMap stack:
aload 2
invokeinterface io.vertx.ext.stomp.StompServerConnection.server:()Lio/vertx/ext/stomp/StompServer;
invokeinterface io.vertx.ext.stomp.StompServer.options:()Lio/vertx/ext/stomp/StompServerOptions;
invokevirtual io.vertx.ext.stomp.StompServerOptions.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;
8: 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;
9: invokestatic io.vertx.ext.stomp.Frame$Heartbeat.computePingPeriod:(Lio/vertx/ext/stomp/Frame$Heartbeat;Lio/vertx/ext/stomp/Frame$Heartbeat;)J
lstore 5
start local 5 10: aload 2
invokeinterface io.vertx.ext.stomp.StompServerConnection.server:()Lio/vertx/ext/stomp/StompServer;
invokeinterface io.vertx.ext.stomp.StompServer.options:()Lio/vertx/ext/stomp/StompServerOptions;
invokevirtual io.vertx.ext.stomp.StompServerOptions.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;
11: 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;
12: invokestatic io.vertx.ext.stomp.Frame$Heartbeat.computePongPeriod:(Lio/vertx/ext/stomp/Frame$Heartbeat;Lio/vertx/ext/stomp/Frame$Heartbeat;)J
lstore 7
start local 7 13: aload 2
lload 5
lload 7
aload 4
invokeinterface io.vertx.ext.stomp.StompServerConnection.configureHeartbeat:(JJLio/vertx/core/Handler;)V
14: aload 3
ifnull 16
15: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
16: StackMap locals: long long
StackMap stack:
return
end local 7 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/DefaultStompHandler;
0 17 1 frame Lio/vertx/ext/stomp/Frame;
0 17 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 5 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
7 17 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
3 5 4 pingH Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;
7 17 4 pingH Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;
10 17 5 ping J
13 17 7 pong J
Exception table:
from to target type
1 4 5 any
5 6 5 any
MethodParameters:
Name Flags
frame
connection
private void handleDisconnect(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.disconnectHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnull 8
7: aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 frame Lio/vertx/ext/stomp/Frame;
0 9 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 9 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
private void handleStomp(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.StompServerConnection);
descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.stompHandler:Lio/vertx/core/Handler;
astore 3
start local 3 2: aload 4
monitorexit
3: goto 6
end local 3 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 4
monitorexit
5: athrow
start local 3 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection io.vertx.core.Handler
StackMap stack:
aload 3
ifnonnull 9
7: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handleConnect:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
8: return
9: StackMap locals:
StackMap stack:
aload 3
new io.vertx.ext.stomp.impl.ServerFrameImpl
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.ServerFrameImpl.<init>:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
10: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 11 1 frame Lio/vertx/ext/stomp/Frame;
0 11 2 connection Lio/vertx/ext/stomp/StompServerConnection;
2 4 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
6 11 3 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
MethodParameters:
Name Flags
frame
connection
public synchronized io.vertx.ext.stomp.StompServerHandler authProvider(io.vertx.ext.auth.authentication.AuthenticationProvider);
descriptor: (Lio/vertx/ext/auth/authentication/AuthenticationProvider;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.authProvider:Lio/vertx/ext/auth/authentication/AuthenticationProvider;
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/DefaultStompHandler;
0 2 1 handler Lio/vertx/ext/auth/authentication/AuthenticationProvider;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.lang.Boolean> onAuthenticationRequest(io.vertx.ext.stomp.StompServerConnection, java.lang.String, java.lang.String);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.context:Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 1: aload 0
aload 1
aload 2
aload 3
aload 4
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.onAuthenticationRequest:(Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
pop
2: aload 4
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
areturn
end local 4 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/DefaultStompHandler;
0 3 1 connection Lio/vertx/ext/stomp/StompServerConnection;
0 3 2 login Ljava/lang/String;
0 3 3 passcode Ljava/lang/String;
1 3 4 promise Lio/vertx/core/impl/future/PromiseInternal<Ljava/lang/Boolean;>;
Signature: (Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Boolean;>;
MethodParameters:
Name Flags
connection
login
passcode
public io.vertx.ext.stomp.StompServerHandler onAuthenticationRequest(io.vertx.ext.stomp.StompServerConnection, java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Boolean>>);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
dup
astore 6
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.authProvider:Lio/vertx/ext/auth/authentication/AuthenticationProvider;
astore 5
start local 5 2: aload 6
monitorexit
3: goto 6
end local 5 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.StompServerConnection java.lang.String java.lang.String io.vertx.core.Handler top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 6
monitorexit
5: athrow
start local 5 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.StompServerConnection java.lang.String java.lang.String io.vertx.core.Handler io.vertx.ext.auth.authentication.AuthenticationProvider
StackMap stack:
aload 1
invokeinterface io.vertx.ext.stomp.StompServerConnection.server:()Lio/vertx/ext/stomp/StompServer;
astore 6
start local 6 7: aload 6
invokeinterface io.vertx.ext.stomp.StompServer.options:()Lio/vertx/ext/stomp/StompServerOptions;
invokevirtual io.vertx.ext.stomp.StompServerOptions.isSecured:()Z
ifne 12
8: aload 5
ifnull 10
9: getstatic io.vertx.ext.stomp.impl.DefaultStompHandler.LOGGER:Lio/vertx/core/impl/logging/Logger;
ldc "Authentication handler set while the server is not secured"
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
10: StackMap locals: io.vertx.ext.stomp.StompServer
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.context:Lio/vertx/core/Context;
aload 4
invokedynamic handle(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/ext/stomp/impl/DefaultStompHandler.lambda$6(Lio/vertx/core/Handler;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
11: aload 0
areturn
12: StackMap locals:
StackMap stack:
aload 6
invokeinterface io.vertx.ext.stomp.StompServer.options:()Lio/vertx/ext/stomp/StompServerOptions;
invokevirtual io.vertx.ext.stomp.StompServerOptions.isSecured:()Z
ifeq 16
aload 5
ifnonnull 16
13: getstatic io.vertx.ext.stomp.impl.DefaultStompHandler.LOGGER:Lio/vertx/core/impl/logging/Logger;
ldc "Cannot authenticate connection - no authentication provider"
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
14: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.context:Lio/vertx/core/Context;
aload 4
invokedynamic handle(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/ext/stomp/impl/DefaultStompHandler.lambda$7(Lio/vertx/core/Handler;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
15: aload 0
areturn
16: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.context:Lio/vertx/core/Context;
aload 0
aload 5
aload 2
aload 3
aload 1
aload 4
invokedynamic handle(Lio/vertx/ext/stomp/impl/DefaultStompHandler;Lio/vertx/ext/auth/authentication/AuthenticationProvider;Ljava/lang/String;Ljava/lang/String;Lio/vertx/ext/stomp/StompServerConnection;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/DefaultStompHandler.lambda$8(Lio/vertx/ext/auth/authentication/AuthenticationProvider;Ljava/lang/String;Ljava/lang/String;Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
17: aload 0
areturn
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 18 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 18 1 connection Lio/vertx/ext/stomp/StompServerConnection;
0 18 2 login Ljava/lang/String;
0 18 3 passcode Ljava/lang/String;
0 18 4 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;
2 4 5 auth Lio/vertx/ext/auth/authentication/AuthenticationProvider;
6 18 5 auth Lio/vertx/ext/auth/authentication/AuthenticationProvider;
7 18 6 server Lio/vertx/ext/stomp/StompServer;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
connection
login
passcode
handler
public io.vertx.ext.auth.User getUserBySession(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/auth/User;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.users:Ljava/util/concurrent/ConcurrentHashMap;
aload 1
invokevirtual java.util.concurrent.ConcurrentHashMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.ext.auth.User
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 1 1 session Ljava/lang/String;
MethodParameters:
Name Flags
session
public java.util.List<io.vertx.ext.stomp.Destination> getDestinations();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.util.ArrayList
dup
aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.destinations:Lio/vertx/core/shareddata/LocalMap;
invokeinterface io.vertx.core.shareddata.LocalMap.keySet:()Ljava/util/Set;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
Signature: ()Ljava/util/List<Lio/vertx/ext/stomp/Destination;>;
public io.vertx.ext.stomp.Destination getDestination(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/Destination;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.destinations:Lio/vertx/core/shareddata/LocalMap;
invokeinterface io.vertx.core.shareddata.LocalMap.keySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 3
goto 4
StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler java.lang.String top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.ext.stomp.Destination
astore 2
start local 2 2: aload 2
aload 1
invokeinterface io.vertx.ext.stomp.Destination.matches:(Ljava/lang/String;)Z
ifeq 4
3: aload 2
areturn
end local 2 4: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
5: aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 6 1 destination Ljava/lang/String;
2 4 2 d Lio/vertx/ext/stomp/Destination;
MethodParameters:
Name Flags
destination
public io.vertx.ext.stomp.Destination getOrCreateDestination(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/stomp/Destination;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.factory:Lio/vertx/ext/stomp/DestinationFactory;
astore 2
start local 2 2: aload 3
monitorexit
3: goto 6
end local 2 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler java.lang.String top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 3
monitorexit
5: athrow
start local 2 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler java.lang.String io.vertx.ext.stomp.DestinationFactory
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.vertx:Lio/vertx/core/Vertx;
dup
astore 3
monitorenter
7: aload 0
aload 1
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.getDestination:(Ljava/lang/String;)Lio/vertx/ext/stomp/Destination;
astore 4
start local 4 8: aload 4
ifnonnull 12
9: aload 2
aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.vertx:Lio/vertx/core/Vertx;
aload 1
invokeinterface io.vertx.ext.stomp.DestinationFactory.create:(Lio/vertx/core/Vertx;Ljava/lang/String;)Lio/vertx/ext/stomp/Destination;
astore 4
10: aload 4
ifnull 12
11: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.destinations:Lio/vertx/core/shareddata/LocalMap;
aload 4
ldc ""
invokeinterface io.vertx.core.shareddata.LocalMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
12: StackMap locals: io.vertx.core.Vertx io.vertx.ext.stomp.Destination
StackMap stack:
aload 4
aload 3
monitorexit
13: areturn
end local 4 14: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler java.lang.String io.vertx.ext.stomp.DestinationFactory io.vertx.core.Vertx
StackMap stack: java.lang.Throwable
aload 3
monitorexit
15: athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 16 1 destination Ljava/lang/String;
2 4 2 destinationFactory Lio/vertx/ext/stomp/DestinationFactory;
6 16 2 destinationFactory Lio/vertx/ext/stomp/DestinationFactory;
8 14 4 d Lio/vertx/ext/stomp/Destination;
Exception table:
from to target type
1 3 4 any
4 5 4 any
7 13 14 any
14 15 14 any
MethodParameters:
Name Flags
destination
public synchronized io.vertx.ext.stomp.StompServerHandler destinationFactory(io.vertx.ext.stomp.DestinationFactory);
descriptor: (Lio/vertx/ext/stomp/DestinationFactory;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.factory:Lio/vertx/ext/stomp/DestinationFactory;
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/DefaultStompHandler;
0 2 1 factory Lio/vertx/ext/stomp/DestinationFactory;
MethodParameters:
Name Flags
factory
public synchronized io.vertx.ext.stomp.StompServerHandler bridge(io.vertx.ext.stomp.BridgeOptions);
descriptor: (Lio/vertx/ext/stomp/BridgeOptions;)Lio/vertx/ext/stomp/StompServerHandler;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.destinations:Lio/vertx/core/shareddata/LocalMap;
aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.vertx:Lio/vertx/core/Vertx;
aload 1
invokestatic io.vertx.ext.stomp.Destination.bridge:(Lio/vertx/core/Vertx;Lio/vertx/ext/stomp/BridgeOptions;)Lio/vertx/ext/stomp/Destination;
ldc ""
invokeinterface io.vertx.core.shareddata.LocalMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
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/DefaultStompHandler;
0 2 1 options Lio/vertx/ext/stomp/BridgeOptions;
MethodParameters:
Name Flags
options
public io.vertx.ext.stomp.StompServerHandler onAck(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Frame, java.util.List<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;Ljava/util/List;)Lio/vertx/ext/stomp/StompServerHandler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
dup
astore 5
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.onAckHandler:Lio/vertx/core/Handler;
astore 4
start local 4 2: aload 5
monitorexit
3: goto 6
end local 4 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame java.util.List top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 5
monitorexit
5: athrow
start local 4 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame java.util.List io.vertx.core.Handler
StackMap stack:
aload 4
ifnull 8
7: aload 4
new io.vertx.ext.stomp.impl.AcknowledgementImpl
dup
aload 2
aload 3
invokespecial io.vertx.ext.stomp.impl.AcknowledgementImpl.<init>:(Lio/vertx/ext/stomp/Frame;Ljava/util/List;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
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 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 connection Lio/vertx/ext/stomp/StompServerConnection;
0 9 2 subscription Lio/vertx/ext/stomp/Frame;
0 9 3 messages Ljava/util/List<Lio/vertx/ext/stomp/Frame;>;
2 4 4 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
6 9 4 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;Ljava/util/List<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
connection
subscription
messages
public io.vertx.ext.stomp.StompServerHandler onNack(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Frame, java.util.List<io.vertx.ext.stomp.Frame>);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;Ljava/util/List;)Lio/vertx/ext/stomp/StompServerHandler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
dup
astore 5
monitorenter
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.onNackHandler:Lio/vertx/core/Handler;
astore 4
start local 4 2: aload 5
monitorexit
3: goto 6
end local 4 StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame java.util.List top io.vertx.ext.stomp.impl.DefaultStompHandler
StackMap stack: java.lang.Throwable
4: aload 5
monitorexit
5: athrow
start local 4 6: StackMap locals: io.vertx.ext.stomp.impl.DefaultStompHandler io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame java.util.List io.vertx.core.Handler
StackMap stack:
aload 4
ifnull 8
7: aload 4
new io.vertx.ext.stomp.impl.AcknowledgementImpl
dup
aload 2
aload 3
invokespecial io.vertx.ext.stomp.impl.AcknowledgementImpl.<init>:(Lio/vertx/ext/stomp/Frame;Ljava/util/List;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
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 9 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 9 1 connection Lio/vertx/ext/stomp/StompServerConnection;
0 9 2 subscribe Lio/vertx/ext/stomp/Frame;
0 9 3 messages Ljava/util/List<Lio/vertx/ext/stomp/Frame;>;
2 4 4 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
6 9 4 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;Ljava/util/List<Lio/vertx/ext/stomp/Frame;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
connection
subscribe
messages
public synchronized io.vertx.ext.stomp.StompServerHandler onAckHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Acknowledgement>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.onAckHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler onNackHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Acknowledgement>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.onNackHandler: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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/Acknowledgement;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.ext.stomp.StompServerHandler pingHandler(io.vertx.core.Handler<io.vertx.ext.stomp.StompServerConnection>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/stomp/StompServerHandler;
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.DefaultStompHandler.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/DefaultStompHandler;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/ext/stomp/StompServerConnection;>;)Lio/vertx/ext/stomp/StompServerHandler;
MethodParameters:
Name Flags
handler
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.ServerFrame
invokevirtual io.vertx.ext.stomp.impl.DefaultStompHandler.handle:(Lio/vertx/ext/stomp/ServerFrame;)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.DefaultStompHandler.$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.DefaultStompHandler.$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.ServerFrame);
descriptor: (Lio/vertx/ext/stomp/ServerFrame;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.ext.stomp.ServerFrame.connection:()Lio/vertx/ext/stomp/StompServerConnection;
astore 1
start local 1 1: aload 0
invokeinterface io.vertx.ext.stomp.ServerFrame.frame:()Lio/vertx/ext/stomp/Frame;
aload 1
invokestatic io.vertx.ext.stomp.Frames.handleReceipt:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
2: aload 1
invokeinterface io.vertx.ext.stomp.StompServerConnection.close:()V
end local 1 3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 sf Lio/vertx/ext/stomp/ServerFrame;
1 3 1 connection Lio/vertx/ext/stomp/StompServerConnection;
private static void lambda$2(io.vertx.ext.stomp.Acknowledgement);
descriptor: (Lio/vertx/ext/stomp/Acknowledgement;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic io.vertx.ext.stomp.impl.DefaultStompHandler.LOGGER:Lio/vertx/core/impl/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Acknowledge messages - "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
1: aload 0
invokeinterface io.vertx.ext.stomp.Acknowledgement.frames:()Ljava/util/List;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
2: invokeinterface io.vertx.core.impl.logging.Logger.info:(Ljava/lang/Object;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 acknowledgement Lio/vertx/ext/stomp/Acknowledgement;
private static void lambda$3(io.vertx.ext.stomp.Acknowledgement);
descriptor: (Lio/vertx/ext/stomp/Acknowledgement;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic io.vertx.ext.stomp.impl.DefaultStompHandler.LOGGER:Lio/vertx/core/impl/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Messages not acknowledge - "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.ext.stomp.Acknowledgement.frames:()Ljava/util/List;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 acknowledgement Lio/vertx/ext/stomp/Acknowledgement;
private static void lambda$5(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Destination);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Destination;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface io.vertx.ext.stomp.Destination.unsubscribeConnection:(Lio/vertx/ext/stomp/StompServerConnection;)Lio/vertx/ext/stomp/Destination;
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 d Lio/vertx/ext/stomp/Destination;
private static void lambda$6(io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
private static void lambda$7(io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
private void lambda$8(io.vertx.ext.auth.authentication.AuthenticationProvider, java.lang.String, java.lang.String, io.vertx.ext.stomp.StompServerConnection, io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/ext/auth/authentication/AuthenticationProvider;Ljava/lang/String;Ljava/lang/String;Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=7, args_size=7
start local 0 start local 6 0: aload 1
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
ldc "username"
aload 2
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
ldc "password"
aload 3
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
aload 0
aload 4
aload 5
invokedynamic handle(Lio/vertx/ext/stomp/impl/DefaultStompHandler;Lio/vertx/ext/stomp/StompServerConnection;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/DefaultStompHandler.lambda$9(Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.ext.auth.authentication.AuthenticationProvider.authenticate:(Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)V
1: return
end local 6 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 2 6 v Ljava/lang/Void;
private void lambda$9(io.vertx.ext.stomp.StompServerConnection, io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.users:Ljava/util/concurrent/ConcurrentHashMap;
aload 1
invokeinterface io.vertx.ext.stomp.StompServerConnection.session:()Ljava/lang/String;
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.ext.auth.User
invokevirtual java.util.concurrent.ConcurrentHashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.context:Lio/vertx/core/Context;
aload 2
invokedynamic handle(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/ext/stomp/impl/DefaultStompHandler.lambda$10(Lio/vertx/core/Handler;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
3: goto 5
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.DefaultStompHandler.context:Lio/vertx/core/Context;
aload 2
invokedynamic handle(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/ext/stomp/impl/DefaultStompHandler.lambda$11(Lio/vertx/core/Handler;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
5: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/stomp/impl/DefaultStompHandler;
0 6 3 ar Lio/vertx/core/AsyncResult<Lio/vertx/ext/auth/User;>;
private static void lambda$10(io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v2 Ljava/lang/Void;
private static void lambda$11(io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v2 Ljava/lang/Void;
}
SourceFile: "DefaultStompHandler.java"
InnerClasses:
public final Command = io.vertx.ext.stomp.Frame$Command of io.vertx.ext.stomp.Frame
public Heartbeat = io.vertx.ext.stomp.Frame$Heartbeat of io.vertx.ext.stomp.Frame
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
DefaultStompHandler
LOGGER: Logger
<clinit>(): void
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-stomp: Stomp support for Vert.x 3
(Eclipse)