public class io.vertx.mqtt.impl.MqttServerImpl implements io.vertx.mqtt.MqttServer
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.mqtt.impl.MqttServerImpl
super_class: java.lang.Object
{
private static final io.vertx.core.impl.logging.Logger log;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.NetServer server;
descriptor: Lio/vertx/core/net/NetServer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.core.Handler<io.vertx.mqtt.MqttEndpoint> endpointHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;
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 io.vertx.mqtt.MqttServerOptions options;
descriptor: Lio/vertx/mqtt/MqttServerOptions;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/mqtt/impl/MqttServerImpl;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.mqtt.impl.MqttServerImpl.log:Lio/vertx/core/impl/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.Vertx, io.vertx.mqtt.MqttServerOptions);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/mqtt/MqttServerOptions;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.mqtt.impl.MqttServerImpl.vertx:Lio/vertx/core/impl/VertxInternal;
2: aload 0
aload 1
aload 2
invokeinterface io.vertx.core.Vertx.createNetServer:(Lio/vertx/core/net/NetServerOptions;)Lio/vertx/core/net/NetServer;
putfield io.vertx.mqtt.impl.MqttServerImpl.server:Lio/vertx/core/net/NetServer;
3: aload 0
aload 2
putfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 5 1 vertx Lio/vertx/core/Vertx;
0 5 2 options Lio/vertx/mqtt/MqttServerOptions;
MethodParameters:
Name Flags
vertx
options
public io.vertx.core.Future<io.vertx.mqtt.MqttServer> listen();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokevirtual io.vertx.mqtt.MqttServerOptions.getPort:()I
invokevirtual io.vertx.mqtt.impl.MqttServerImpl.listen:(I)Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
Signature: ()Lio/vertx/core/Future<Lio/vertx/mqtt/MqttServer;>;
public io.vertx.core.Future<io.vertx.mqtt.MqttServer> listen(int, java.lang.String);
descriptor: (ILjava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.endpointHandler:Lio/vertx/core/Handler;
astore 3
start local 3 1: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.exceptionHandler:Lio/vertx/core/Handler;
astore 4
start local 4 2: aload 3
ifnonnull 4
3: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
new java.lang.IllegalStateException
dup
ldc "Please set handler before server is listening"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
areturn
4: StackMap locals: io.vertx.core.Handler io.vertx.core.Handler
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.server:Lio/vertx/core/net/NetServer;
aload 0
aload 3
aload 4
invokedynamic handle(Lio/vertx/mqtt/impl/MqttServerImpl;Lio/vertx/core/Handler;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/mqtt/impl/MqttServerImpl.lambda$0(Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/net/NetSocket;)V (7)
(Lio/vertx/core/net/NetSocket;)V
invokeinterface io.vertx.core.net.NetServer.connectHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetServer;
pop
5: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.server:Lio/vertx/core/net/NetServer;
iload 1
aload 2
invokeinterface io.vertx.core.net.NetServer.listen:(ILjava/lang/String;)Lio/vertx/core/Future;
aload 0
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)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 6 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 6 1 port I
0 6 2 host Ljava/lang/String;
1 6 3 h1 Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;
2 6 4 h2 Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (ILjava/lang/String;)Lio/vertx/core/Future<Lio/vertx/mqtt/MqttServer;>;
MethodParameters:
Name Flags
port
host
public io.vertx.core.Future<io.vertx.mqtt.MqttServer> listen(int);
descriptor: (I)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokevirtual io.vertx.mqtt.MqttServerOptions.getHost:()Ljava/lang/String;
invokevirtual io.vertx.mqtt.impl.MqttServerImpl.listen:(ILjava/lang/String;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 1 1 port I
Signature: (I)Lio/vertx/core/Future<Lio/vertx/mqtt/MqttServer;>;
MethodParameters:
Name Flags
port
public io.vertx.mqtt.MqttServer listen(int, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.mqtt.MqttServer>>);
descriptor: (ILio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
iload 1
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokevirtual io.vertx.mqtt.MqttServerOptions.getHost:()Ljava/lang/String;
aload 2
invokevirtual io.vertx.mqtt.impl.MqttServerImpl.listen:(ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 1 1 port I
0 1 2 listenHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;>;
Signature: (ILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;>;)Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
port
listenHandler
public io.vertx.mqtt.MqttServer listen(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.mqtt.MqttServer>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokevirtual io.vertx.mqtt.MqttServerOptions.getPort:()I
aload 1
invokevirtual io.vertx.mqtt.impl.MqttServerImpl.listen:(ILio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 1 1 listenHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;>;)Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
listenHandler
public io.vertx.mqtt.MqttServer listen(int, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.mqtt.MqttServer>>);
descriptor: (ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
aload 2
invokevirtual io.vertx.mqtt.impl.MqttServerImpl.listen:(ILjava/lang/String;)Lio/vertx/core/Future;
astore 4
start local 4 1: aload 3
ifnull 3
2: aload 4
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: StackMap locals: io.vertx.core.Future
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 4 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 4 1 port I
0 4 2 host Ljava/lang/String;
0 4 3 listenHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;>;
1 4 4 fut Lio/vertx/core/Future<Lio/vertx/mqtt/MqttServer;>;
Signature: (ILjava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;>;)Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
port
host
listenHandler
public synchronized io.vertx.mqtt.MqttServer endpointHandler(io.vertx.core.Handler<io.vertx.mqtt.MqttEndpoint>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
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.mqtt.impl.MqttServerImpl.endpointHandler: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/mqtt/impl/MqttServerImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/MqttEndpoint;>;)Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
handler
public synchronized io.vertx.mqtt.MqttServer exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
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.mqtt.impl.MqttServerImpl.exceptionHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
handler
public int actualPort();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.server:Lio/vertx/core/net/NetServer;
invokeinterface io.vertx.core.net.NetServer.actualPort:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.server:Lio/vertx/core/net/NetServer;
invokeinterface io.vertx.core.net.NetServer.close:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.server:Lio/vertx/core/net/NetServer;
aload 1
invokeinterface io.vertx.core.net.NetServer.close:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 2 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
private void initChannel(io.netty.channel.ChannelPipeline);
descriptor: (Lio/netty/channel/ChannelPipeline;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "handler"
ldc "mqttEncoder"
getstatic io.netty.handler.codec.mqtt.MqttEncoder.INSTANCE:Lio/netty/handler/codec/mqtt/MqttEncoder;
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
1: aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokevirtual io.vertx.mqtt.MqttServerOptions.getMaxMessageSize:()I
ifle 4
2: aload 1
ldc "handler"
ldc "mqttDecoder"
new io.netty.handler.codec.mqtt.MqttDecoder
dup
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokevirtual io.vertx.mqtt.MqttServerOptions.getMaxMessageSize:()I
invokespecial io.netty.handler.codec.mqtt.MqttDecoder.<init>:(I)V
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
3: goto 5
4: StackMap locals:
StackMap stack:
aload 1
ldc "handler"
ldc "mqttDecoder"
new io.netty.handler.codec.mqtt.MqttDecoder
dup
invokespecial io.netty.handler.codec.mqtt.MqttDecoder.<init>:()V
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
5: StackMap locals:
StackMap stack:
aload 1
ldc "handler"
ldc "idle"
new io.netty.handler.timeout.IdleStateHandler
dup
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokevirtual io.vertx.mqtt.MqttServerOptions.timeoutOnConnect:()I
iconst_0
iconst_0
invokespecial io.netty.handler.timeout.IdleStateHandler.<init>:(III)V
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
6: aload 1
ldc "handler"
ldc "timeoutOnConnect"
new io.vertx.mqtt.impl.MqttServerImpl$1
dup
aload 0
invokespecial io.vertx.mqtt.impl.MqttServerImpl$1.<init>:(Lio/vertx/mqtt/impl/MqttServerImpl;)V
invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 8 1 pipeline Lio/netty/channel/ChannelPipeline;
MethodParameters:
Name Flags
pipeline
private void lambda$0(io.vertx.core.Handler, io.vertx.core.Handler, io.vertx.core.net.NetSocket);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/core/net/NetSocket;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=7, args_size=4
start local 0 start local 3 0: aload 3
checkcast io.vertx.core.net.impl.NetSocketInternal
astore 4
start local 4 1: aload 4
invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 5
start local 5 2: aload 0
aload 5
invokevirtual io.vertx.mqtt.impl.MqttServerImpl.initChannel:(Lio/netty/channel/ChannelPipeline;)V
3: new io.vertx.mqtt.impl.MqttServerConnection
dup
aload 4
aload 1
aload 2
aload 0
getfield io.vertx.mqtt.impl.MqttServerImpl.options:Lio/vertx/mqtt/MqttServerOptions;
invokespecial io.vertx.mqtt.impl.MqttServerConnection.<init>:(Lio/vertx/core/net/impl/NetSocketInternal;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Lio/vertx/mqtt/MqttServerOptions;)V
astore 6
start local 6 4: aload 4
aload 6
invokedynamic handle(Lio/vertx/mqtt/impl/MqttServerConnection;)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/mqtt/impl/MqttServerImpl.lambda$1(Lio/vertx/mqtt/impl/MqttServerConnection;Ljava/lang/Object;)V (6)
(Ljava/lang/Object;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
pop
end local 6 end local 5 end local 4 5: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/mqtt/impl/MqttServerImpl;
0 6 3 so Lio/vertx/core/net/NetSocket;
1 5 4 soi Lio/vertx/core/net/impl/NetSocketInternal;
2 5 5 pipeline Lio/netty/channel/ChannelPipeline;
4 5 6 conn Lio/vertx/mqtt/impl/MqttServerConnection;
private static void lambda$1(io.vertx.mqtt.impl.MqttServerConnection, java.lang.Object);
descriptor: (Lio/vertx/mqtt/impl/MqttServerConnection;Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
aload 1
invokevirtual io.vertx.mqtt.impl.MqttServerConnection.handleMessage:(Ljava/lang/Object;)V
2: aload 2
monitorexit
3: goto 6
StackMap locals: io.vertx.mqtt.impl.MqttServerConnection java.lang.Object io.vertx.mqtt.impl.MqttServerConnection
StackMap stack: java.lang.Throwable
4: aload 2
monitorexit
5: athrow
6: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 7 1 msg Ljava/lang/Object;
Exception table:
from to target type
1 3 4 any
4 5 4 any
}
SourceFile: "MqttServerImpl.java"
NestMembers:
io.vertx.mqtt.impl.MqttServerImpl$1
InnerClasses:
io.vertx.mqtt.impl.MqttServerImpl$1
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles