public class examples.VertxMqttServerExamples
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: examples.VertxMqttServerExamples
super_class: java.lang.Object
{
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lexamples/VertxMqttServerExamples;
public void example1(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokestatic io.vertx.mqtt.MqttServer.create:(Lio/vertx/core/Vertx;)Lio/vertx/mqtt/MqttServer;
astore 2
start local 2 1: aload 2
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
examples/VertxMqttServerExamples.lambda$0(Lio/vertx/mqtt/MqttEndpoint;)V (6)
(Lio/vertx/mqtt/MqttEndpoint;)V
invokeinterface io.vertx.mqtt.MqttServer.endpointHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
2: 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
examples/VertxMqttServerExamples.lambda$1(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.mqtt.MqttServer.listen:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
pop
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lexamples/VertxMqttServerExamples;
0 4 1 vertx Lio/vertx/core/Vertx;
1 4 2 mqttServer Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
vertx
public void example2(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
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
examples/VertxMqttServerExamples.lambda$2(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.disconnectHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxMqttServerExamples;
0 2 1 endpoint Lio/vertx/mqtt/MqttEndpoint;
MethodParameters:
Name Flags
endpoint
public void example3(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: new io.vertx.mqtt.MqttServerOptions
dup
invokespecial io.vertx.mqtt.MqttServerOptions.<init>:()V
1: sipush 8883
invokevirtual io.vertx.mqtt.MqttServerOptions.setPort:(I)Lio/vertx/mqtt/MqttServerOptions;
2: new io.vertx.core.net.PemKeyCertOptions
dup
invokespecial io.vertx.core.net.PemKeyCertOptions.<init>:()V
3: ldc "./src/test/resources/tls/server-key.pem"
invokevirtual io.vertx.core.net.PemKeyCertOptions.setKeyPath:(Ljava/lang/String;)Lio/vertx/core/net/PemKeyCertOptions;
4: ldc "./src/test/resources/tls/server-cert.pem"
invokevirtual io.vertx.core.net.PemKeyCertOptions.setCertPath:(Ljava/lang/String;)Lio/vertx/core/net/PemKeyCertOptions;
5: invokevirtual io.vertx.mqtt.MqttServerOptions.setKeyCertOptions:(Lio/vertx/core/net/KeyCertOptions;)Lio/vertx/mqtt/MqttServerOptions;
6: iconst_1
invokevirtual io.vertx.mqtt.MqttServerOptions.setSsl:(Z)Lio/vertx/mqtt/MqttServerOptions;
7: astore 2
start local 2 8: aload 1
aload 2
invokestatic io.vertx.mqtt.MqttServer.create:(Lio/vertx/core/Vertx;Lio/vertx/mqtt/MqttServerOptions;)Lio/vertx/mqtt/MqttServer;
astore 3
start local 3 9: aload 3
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
examples/VertxMqttServerExamples.lambda$3(Lio/vertx/mqtt/MqttEndpoint;)V (6)
(Lio/vertx/mqtt/MqttEndpoint;)V
invokeinterface io.vertx.mqtt.MqttServer.endpointHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
10: 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
examples/VertxMqttServerExamples.lambda$4(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.mqtt.MqttServer.listen:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
pop
11: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lexamples/VertxMqttServerExamples;
0 12 1 vertx Lio/vertx/core/Vertx;
8 12 2 options Lio/vertx/mqtt/MqttServerOptions;
9 12 3 mqttServer Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
vertx
public void example4(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 1
invokedynamic handle(Lio/vertx/mqtt/MqttEndpoint;)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
examples/VertxMqttServerExamples.lambda$5(Lio/vertx/mqtt/MqttEndpoint;Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V (6)
(Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.subscribeHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxMqttServerExamples;
0 2 1 endpoint Lio/vertx/mqtt/MqttEndpoint;
MethodParameters:
Name Flags
endpoint
public void example5(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 1
invokedynamic handle(Lio/vertx/mqtt/MqttEndpoint;)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
examples/VertxMqttServerExamples.lambda$6(Lio/vertx/mqtt/MqttEndpoint;Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V (6)
(Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.unsubscribeHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxMqttServerExamples;
0 2 1 endpoint Lio/vertx/mqtt/MqttEndpoint;
MethodParameters:
Name Flags
endpoint
public void example6(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 1
invokedynamic handle(Lio/vertx/mqtt/MqttEndpoint;)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
examples/VertxMqttServerExamples.lambda$7(Lio/vertx/mqtt/MqttEndpoint;Lio/vertx/mqtt/messages/MqttPublishMessage;)V (6)
(Lio/vertx/mqtt/messages/MqttPublishMessage;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.publishHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
1: aload 1
invokedynamic handle(Lio/vertx/mqtt/MqttEndpoint;)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
examples/VertxMqttServerExamples.lambda$8(Lio/vertx/mqtt/MqttEndpoint;Ljava/lang/Integer;)V (6)
(Ljava/lang/Integer;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.publishReleaseHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lexamples/VertxMqttServerExamples;
0 3 1 endpoint Lio/vertx/mqtt/MqttEndpoint;
MethodParameters:
Name Flags
endpoint
public void example7(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "my_topic"
1: ldc "Hello from the Vert.x MQTT server"
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
2: getstatic io.netty.handler.codec.mqtt.MqttQoS.EXACTLY_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
3: iconst_0
4: iconst_0
5: invokeinterface io.vertx.mqtt.MqttEndpoint.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)Lio/vertx/core/Future;
pop
6: aload 1
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
examples/VertxMqttServerExamples.lambda$9(Ljava/lang/Integer;)V (6)
(Ljava/lang/Integer;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.publishAcknowledgeHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
7: aload 1
invokedynamic handle(Lio/vertx/mqtt/MqttEndpoint;)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
examples/VertxMqttServerExamples.lambda$10(Lio/vertx/mqtt/MqttEndpoint;Ljava/lang/Integer;)V (6)
(Ljava/lang/Integer;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.publishReceivedHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
8: 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
examples/VertxMqttServerExamples.lambda$11(Ljava/lang/Integer;)V (6)
(Ljava/lang/Integer;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.publishCompletionHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
pop
9: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lexamples/VertxMqttServerExamples;
0 10 1 endpoint Lio/vertx/mqtt/MqttEndpoint;
MethodParameters:
Name Flags
endpoint
public void example8(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
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
examples/VertxMqttServerExamples.lambda$12(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.mqtt.MqttEndpoint.pingHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxMqttServerExamples;
0 2 1 endpoint Lio/vertx/mqtt/MqttEndpoint;
MethodParameters:
Name Flags
endpoint
public void example9(io.vertx.mqtt.MqttServer);
descriptor: (Lio/vertx/mqtt/MqttServer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
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
examples/VertxMqttServerExamples.lambda$13(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.mqtt.MqttServer.close:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxMqttServerExamples;
0 2 1 mqttServer Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
mqttServer
public void example10(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: goto 6
2: StackMap locals: int
StackMap stack:
aload 1
invokestatic io.vertx.mqtt.MqttServer.create:(Lio/vertx/core/Vertx;)Lio/vertx/mqtt/MqttServer;
astore 3
start local 3 3: aload 3
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
examples/VertxMqttServerExamples.lambda$14(Lio/vertx/mqtt/MqttEndpoint;)V (6)
(Lio/vertx/mqtt/MqttEndpoint;)V
invokeinterface io.vertx.mqtt.MqttServer.endpointHandler:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
4: 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
examples/VertxMqttServerExamples.lambda$15(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.mqtt.MqttServer.listen:(Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttServer;
pop
end local 3 5: iinc 2 1
StackMap locals:
StackMap stack:
6: iload 2
bipush 10
if_icmplt 2
end local 2 7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxMqttServerExamples;
0 8 1 vertx Lio/vertx/core/Vertx;
1 7 2 i I
3 5 3 mqttServer Lio/vertx/mqtt/MqttServer;
MethodParameters:
Name Flags
vertx
public void example11(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.core.DeploymentOptions
dup
invokespecial io.vertx.core.DeploymentOptions.<init>:()V
bipush 10
invokevirtual io.vertx.core.DeploymentOptions.setInstances:(I)Lio/vertx/core/DeploymentOptions;
astore 2
start local 2 1: aload 1
ldc "com.mycompany.MyVerticle"
aload 2
invokeinterface io.vertx.core.Vertx.deployVerticle:(Ljava/lang/String;Lio/vertx/core/DeploymentOptions;)Lio/vertx/core/Future;
pop
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lexamples/VertxMqttServerExamples;
0 3 1 vertx Lio/vertx/core/Vertx;
1 3 2 options Lio/vertx/core/DeploymentOptions;
MethodParameters:
Name Flags
vertx
private static void lambda$0(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "MQTT client ["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.clientIdentifier:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "] request to connect, clean session = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.isCleanSession:()Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.auth:()Lio/vertx/mqtt/MqttAuth;
ifnull 3
2: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "[username = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.auth:()Lio/vertx/mqtt/MqttAuth;
invokevirtual io.vertx.mqtt.MqttAuth.getUsername:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", password = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.auth:()Lio/vertx/mqtt/MqttAuth;
invokevirtual io.vertx.mqtt.MqttAuth.getPassword:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: StackMap locals:
StackMap stack:
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
ifnull 7
4: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "[will topic = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.getWillTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " msg = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
new java.lang.String
dup
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.getWillMessageBytes:()[B
invokespecial java.lang.String.<init>:([B)V
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
5: ldc " QoS = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.getWillQos:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " isRetain = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.isWillRetain:()Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
6: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "[keep alive timeout = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.keepAliveTimeSeconds:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
8: aload 0
iconst_0
invokeinterface io.vertx.mqtt.MqttEndpoint.accept:(Z)Lio/vertx/mqtt/MqttEndpoint;
pop
9: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 endpoint Lio/vertx/mqtt/MqttEndpoint;
private static void lambda$1(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "MQTT server is listening on port "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.mqtt.MqttServer
invokeinterface io.vertx.mqtt.MqttServer.actualPort:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: goto 5
3: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Error on starting the server"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 ar Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;
private static void lambda$2(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Received disconnect from client"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 v Ljava/lang/Void;
private static void lambda$3(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "MQTT client ["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.clientIdentifier:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "] request to connect, clean session = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.isCleanSession:()Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.auth:()Lio/vertx/mqtt/MqttAuth;
ifnull 3
2: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "[username = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.auth:()Lio/vertx/mqtt/MqttAuth;
invokevirtual io.vertx.mqtt.MqttAuth.getUsername:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", password = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.auth:()Lio/vertx/mqtt/MqttAuth;
invokevirtual io.vertx.mqtt.MqttAuth.getPassword:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: StackMap locals:
StackMap stack:
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
ifnull 7
4: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "[will topic = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.getWillTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " msg = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
new java.lang.String
dup
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.getWillMessageBytes:()[B
invokespecial java.lang.String.<init>:([B)V
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
5: ldc " QoS = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.getWillQos:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " isRetain = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.will:()Lio/vertx/mqtt/MqttWill;
invokevirtual io.vertx.mqtt.MqttWill.isWillRetain:()Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
6: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "[keep alive timeout = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.mqtt.MqttEndpoint.keepAliveTimeSeconds:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
8: aload 0
iconst_0
invokeinterface io.vertx.mqtt.MqttEndpoint.accept:(Z)Lio/vertx/mqtt/MqttEndpoint;
pop
9: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 endpoint Lio/vertx/mqtt/MqttEndpoint;
private static void lambda$4(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "MQTT server is listening on port "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.mqtt.MqttServer
invokeinterface io.vertx.mqtt.MqttServer.actualPort:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: goto 5
3: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Error on starting the server"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 ar Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;
private static void lambda$5(io.vertx.mqtt.MqttEndpoint, io.vertx.mqtt.messages.MqttSubscribeMessage);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;Lio/vertx/mqtt/messages/MqttSubscribeMessage;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=2
start local 1 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 1: aload 1
invokeinterface io.vertx.mqtt.messages.MqttSubscribeMessage.topicSubscriptions:()Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 5
StackMap locals: io.vertx.mqtt.MqttEndpoint io.vertx.mqtt.messages.MqttSubscribeMessage java.util.List top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.mqtt.MqttTopicSubscription
astore 3
start local 3 3: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Subscription for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokeinterface io.vertx.mqtt.MqttTopicSubscription.topicName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " with QoS "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokeinterface io.vertx.mqtt.MqttTopicSubscription.qualityOfService:()Lio/netty/handler/codec/mqtt/MqttQoS;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: aload 2
aload 3
invokeinterface io.vertx.mqtt.MqttTopicSubscription.qualityOfService:()Lio/netty/handler/codec/mqtt/MqttQoS;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 3 5: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
6: aload 0
aload 1
invokeinterface io.vertx.mqtt.messages.MqttSubscribeMessage.messageId:()I
aload 2
invokeinterface io.vertx.mqtt.MqttEndpoint.subscribeAcknowledge:(ILjava/util/List;)Lio/vertx/mqtt/MqttEndpoint;
pop
end local 2 7: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 8 1 subscribe Lio/vertx/mqtt/messages/MqttSubscribeMessage;
1 7 2 grantedQosLevels Ljava/util/List<Lio/netty/handler/codec/mqtt/MqttQoS;>;
3 5 3 s Lio/vertx/mqtt/MqttTopicSubscription;
private static void lambda$6(io.vertx.mqtt.MqttEndpoint, io.vertx.mqtt.messages.MqttUnsubscribeMessage);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=2
start local 1 0: aload 1
invokeinterface io.vertx.mqtt.messages.MqttUnsubscribeMessage.topics:()Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 3
StackMap locals: io.vertx.mqtt.MqttEndpoint io.vertx.mqtt.messages.MqttUnsubscribeMessage top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 2
start local 2 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Unsubscription for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 2 3: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: aload 0
aload 1
invokeinterface io.vertx.mqtt.messages.MqttUnsubscribeMessage.messageId:()I
invokeinterface io.vertx.mqtt.MqttEndpoint.unsubscribeAcknowledge:(I)Lio/vertx/mqtt/MqttEndpoint;
pop
5: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 6 1 unsubscribe Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;
2 3 2 t Ljava/lang/String;
private static void lambda$7(io.vertx.mqtt.MqttEndpoint, io.vertx.mqtt.messages.MqttPublishMessage);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;Lio/vertx/mqtt/messages/MqttPublishMessage;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 1 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Just received message ["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.payload:()Lio/vertx/core/buffer/Buffer;
invokestatic java.nio.charset.Charset.defaultCharset:()Ljava/nio/charset/Charset;
invokeinterface io.vertx.core.buffer.Buffer.toString:(Ljava/nio/charset/Charset;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "] with QoS ["
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_LEAST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
if_acmpne 4
2: aload 0
aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.messageId:()I
invokeinterface io.vertx.mqtt.MqttEndpoint.publishAcknowledge:(I)Lio/vertx/mqtt/MqttEndpoint;
pop
3: goto 6
StackMap locals:
StackMap stack:
4: aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
getstatic io.netty.handler.codec.mqtt.MqttQoS.EXACTLY_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
if_acmpne 6
5: aload 0
aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.messageId:()I
invokeinterface io.vertx.mqtt.MqttEndpoint.publishReceived:(I)Lio/vertx/mqtt/MqttEndpoint;
pop
6: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 7 1 message Lio/vertx/mqtt/messages/MqttPublishMessage;
private static void lambda$8(io.vertx.mqtt.MqttEndpoint, java.lang.Integer);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;Ljava/lang/Integer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokevirtual java.lang.Integer.intValue:()I
invokeinterface io.vertx.mqtt.MqttEndpoint.publishComplete:(I)Lio/vertx/mqtt/MqttEndpoint;
pop
1: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 messageId Ljava/lang/Integer;
private static void lambda$9(java.lang.Integer);
descriptor: (Ljava/lang/Integer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Received ack for message = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 messageId Ljava/lang/Integer;
private static void lambda$10(io.vertx.mqtt.MqttEndpoint, java.lang.Integer);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;Ljava/lang/Integer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokevirtual java.lang.Integer.intValue:()I
invokeinterface io.vertx.mqtt.MqttEndpoint.publishRelease:(I)Lio/vertx/mqtt/MqttEndpoint;
pop
1: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 messageId Ljava/lang/Integer;
private static void lambda$11(java.lang.Integer);
descriptor: (Ljava/lang/Integer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Received ack for message = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 messageId Ljava/lang/Integer;
private static void lambda$12(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Ping received from client"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 v Ljava/lang/Void;
private static void lambda$13(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "MQTT server closed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 v Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private static void lambda$14(io.vertx.mqtt.MqttEndpoint);
descriptor: (Lio/vertx/mqtt/MqttEndpoint;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 endpoint Lio/vertx/mqtt/MqttEndpoint;
private static void lambda$15(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 ar Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/MqttServer;>;
}
SourceFile: "VertxMqttServerExamples.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
RuntimeInvisibleAnnotations:
io.vertx.docgen.Source()