public class io.vertx.mqtt.impl.MqttClientImpl implements io.vertx.mqtt.MqttClient
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.mqtt.impl.MqttClientImpl
super_class: java.lang.Object
{
private static final java.util.regex.Pattern validTopicNamePattern;
descriptor: Ljava/util/regex/Pattern;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.util.regex.Pattern validTopicFilterPattern;
descriptor: Ljava/util/regex/Pattern;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
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 static final int MAX_MESSAGE_ID;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 65535
private static final int MAX_TOPIC_LEN;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 65535
private static final int MIN_TOPIC_LEN;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 1
private static final java.lang.String PROTOCOL_NAME;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "MQTT"
private static final int PROTOCOL_VERSION;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 4
private static final int DEFAULT_IDLE_TIMEOUT;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 0
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.mqtt.MqttClientOptions options;
descriptor: Lio/vertx/mqtt/MqttClientOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.core.net.impl.NetSocketInternal connection;
descriptor: Lio/vertx/core/net/impl/NetSocketInternal;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.impl.ContextInternal ctx;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<java.lang.Integer> publishCompletionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Integer;>;
private io.vertx.core.Handler<java.lang.Integer> publishCompletionExpirationHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Integer;>;
private io.vertx.core.Handler<java.lang.Integer> publishCompletionPhantomHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Integer;>;
private io.vertx.core.Handler<java.lang.Integer> unsubscribeCompletionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Integer;>;
private io.vertx.core.Handler<io.vertx.mqtt.messages.MqttPublishMessage> publishHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;
private io.vertx.core.Handler<io.vertx.mqtt.messages.MqttSubAckMessage> subscribeCompletionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubAckMessage;>;
private io.vertx.core.Promise<io.vertx.mqtt.messages.MqttConnAckMessage> connectPromise;
descriptor: Lio/vertx/core/Promise;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Promise<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
private io.vertx.core.Promise<java.lang.Void> disconnectPromise;
descriptor: Lio/vertx/core/Promise;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Promise<Ljava/lang/Void;>;
private io.vertx.core.Handler<java.lang.Void> pingrespHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
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.core.Handler<java.lang.Void> closeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
private java.util.HashMap<java.lang.Integer, io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket> qos1outbound;
descriptor: Ljava/util/HashMap;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/HashMap<Ljava/lang/Integer;Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;>;
private java.util.HashMap<java.lang.Integer, io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket> qos2outbound;
descriptor: Ljava/util/HashMap;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/HashMap<Ljava/lang/Integer;Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;>;
private java.util.HashMap<java.lang.Integer, io.vertx.mqtt.messages.MqttMessage> qos2inbound;
descriptor: Ljava/util/HashMap;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/HashMap<Ljava/lang/Integer;Lio/vertx/mqtt/messages/MqttMessage;>;
private int messageIdCounter;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private final long keepAliveTimeout;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.util.Deque<io.vertx.mqtt.impl.MqttClientImpl$Ping> pings;
descriptor: Ljava/util/Deque;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Deque<Lio/vertx/mqtt/impl/MqttClientImpl$Ping;>;
private int countInflightQueue;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.net.NetClient client;
descriptor: Lio/vertx/core/net/NetClient;
flags: (0x0002) ACC_PRIVATE
private io.vertx.mqtt.impl.MqttClientImpl$Status status;
descriptor: Lio/vertx/mqtt/impl/MqttClientImpl$Status;
flags: (0x0002) ACC_PRIVATE
private static volatile int[] $SWITCH_TABLE$io$vertx$mqtt$impl$MqttClientImpl$Status;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
private static volatile int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
private static volatile int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType;
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 "^[^#+\\u0000]+$"
invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
putstatic io.vertx.mqtt.impl.MqttClientImpl.validTopicNamePattern:Ljava/util/regex/Pattern;
1: ldc "^(#|((\\+(?![^/]))?([^#+]*(/\\+(?![^/]))?)*(/#)?))$"
invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
putstatic io.vertx.mqtt.impl.MqttClientImpl.validTopicFilterPattern:Ljava/util/regex/Pattern;
2: ldc Lio/vertx/mqtt/impl/MqttClientImpl;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
3: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.Vertx, io.vertx.mqtt.MqttClientOptions);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/mqtt/MqttClientOptions;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.mqtt.impl.MqttClientImpl.qos1outbound:Ljava/util/HashMap;
2: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.mqtt.impl.MqttClientImpl.qos2outbound:Ljava/util/HashMap;
3: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.mqtt.impl.MqttClientImpl.qos2inbound:Ljava/util/HashMap;
4: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.vertx.mqtt.impl.MqttClientImpl.pings:Ljava/util/Deque;
5: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
6: new io.vertx.core.net.NetClientOptions
dup
aload 2
invokespecial io.vertx.core.net.NetClientOptions.<init>:(Lio/vertx/core/net/NetClientOptions;)V
astore 3
start local 3 7: aload 3
iconst_0
invokevirtual io.vertx.core.net.NetClientOptions.setIdleTimeout:(I)Lio/vertx/core/net/NetClientOptions;
pop
8: aload 0
aload 1
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.mqtt.impl.MqttClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
9: aload 0
new io.vertx.mqtt.MqttClientOptions
dup
aload 2
invokespecial io.vertx.mqtt.MqttClientOptions.<init>:(Lio/vertx/mqtt/MqttClientOptions;)V
putfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
10: aload 0
aload 2
invokevirtual io.vertx.mqtt.MqttClientOptions.getKeepAliveInterval:()I
sipush 1000
imul
iconst_3
imul
iconst_2
idiv
i2l
putfield io.vertx.mqtt.impl.MqttClientImpl.keepAliveTimeout:J
11: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 12 1 vertx Lio/vertx/core/Vertx;
0 12 2 options Lio/vertx/mqtt/MqttClientOptions;
7 12 3 netClientOptions Lio/vertx/core/net/NetClientOptions;
MethodParameters:
Name Flags
vertx
options
int getInFlightMessagesCount();
descriptor: ()I
flags: (0x0000)
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
dup
astore 1
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
aload 1
monitorexit
2: ireturn
3: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
aload 1
monitorexit
4: athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Exception table:
from to target type
1 2 3 any
3 4 3 any
public io.vertx.core.Future<io.vertx.mqtt.messages.MqttConnAckMessage> connect(int, java.lang.String);
descriptor: (ILjava/lang/String;)Lio/vertx/core/Future;
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 2
aconst_null
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.doConnect:(ILjava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 1 1 port I
0 1 2 host Ljava/lang/String;
Signature: (ILjava/lang/String;)Lio/vertx/core/Future<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
MethodParameters:
Name Flags
port
host
public io.vertx.mqtt.MqttClient connect(int, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.mqtt.messages.MqttConnAckMessage>>);
descriptor: (ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
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.MqttClientImpl.connect:(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/MqttClientImpl;
0 4 1 port I
0 4 2 host Ljava/lang/String;
0 4 3 connectHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;>;
1 4 4 fut Lio/vertx/core/Future<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
Signature: (ILjava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
port
host
connectHandler
public io.vertx.core.Future<io.vertx.mqtt.messages.MqttConnAckMessage> connect(int, java.lang.String, java.lang.String);
descriptor: (ILjava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
aload 2
aload 3
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.connect:(ILjava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 1 1 port I
0 1 2 host Ljava/lang/String;
0 1 3 serverName Ljava/lang/String;
Signature: (ILjava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
MethodParameters:
Name Flags
port
host
serverName
public io.vertx.mqtt.MqttClient connect(int, java.lang.String, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.mqtt.messages.MqttConnAckMessage>>);
descriptor: (ILjava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
iload 1
aload 2
aload 3
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.doConnect:(ILjava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
astore 5
start local 5 1: aload 4
ifnull 3
2: aload 5
aload 4
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 5 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/MqttClientImpl;
0 4 1 port I
0 4 2 host Ljava/lang/String;
0 4 3 serverName Ljava/lang/String;
0 4 4 connectHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;>;
1 4 5 fut Lio/vertx/core/Future<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
Signature: (ILjava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
port
host
serverName
connectHandler
private io.vertx.core.Future<io.vertx.mqtt.messages.MqttConnAckMessage> doConnect(int, java.lang.String, java.lang.String);
descriptor: (ILjava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
astore 4
start local 4 1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
new io.vertx.core.impl.CloseFuture
dup
invokespecial io.vertx.core.impl.CloseFuture.<init>:()V
invokeinterface io.vertx.core.impl.VertxInternal.createNetClient:(Lio/vertx/core/net/NetClientOptions;Lio/vertx/core/impl/CloseFuture;)Lio/vertx/core/net/NetClient;
astore 5
start local 5 2: aload 4
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 6
start local 6 3: aload 4
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 7
start local 7 4: aload 0
dup
astore 8
monitorenter
5: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
if_acmpeq 8
6: aload 4
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Client "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Status.name:()Ljava/lang/String;
invokevirtual java.lang.String.toLowerCase:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
aload 8
monitorexit
7: areturn
8: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int java.lang.String java.lang.String io.vertx.core.impl.ContextInternal io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CONNECTING:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
9: aload 0
aload 4
putfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
10: aload 0
aload 6
putfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
11: aload 0
aload 7
putfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
12: aload 0
aload 5
putfield io.vertx.mqtt.impl.MqttClientImpl.client:Lio/vertx/core/net/NetClient;
13: aload 8
monitorexit
14: goto 17
StackMap locals:
StackMap stack: java.lang.Throwable
15: aload 8
monitorexit
16: athrow
17: StackMap locals:
StackMap stack:
aload 4
aload 0
aload 2
iload 1
aload 5
aload 3
aload 6
aload 7
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;Ljava/lang/String;ILio/vertx/core/net/NetClient;Ljava/lang/String;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;)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/MqttClientImpl.lambda$0(Ljava/lang/String;ILio/vertx/core/net/NetClient;Ljava/lang/String;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)V
18: aload 6
invokeinterface io.vertx.core.impl.future.PromiseInternal.future:()Lio/vertx/core/Future;
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 19 1 port I
0 19 2 host Ljava/lang/String;
0 19 3 serverName Ljava/lang/String;
1 19 4 ctx Lio/vertx/core/impl/ContextInternal;
2 19 5 client Lio/vertx/core/net/NetClient;
3 19 6 connectPromise Lio/vertx/core/impl/future/PromiseInternal<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
4 19 7 disconnectPromise Lio/vertx/core/impl/future/PromiseInternal<Ljava/lang/Void;>;
Exception table:
from to target type
5 7 15 any
8 14 15 any
15 16 15 any
Signature: (ILjava/lang/String;Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
MethodParameters:
Name Flags
port
host
serverName
public io.vertx.core.Future<java.lang.Void> disconnect();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=1
start local 0 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
astore 2
start local 2 2: invokestatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$vertx$mqtt$impl$MqttClientImpl$Status:()[I
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Status.ordinal:()I
iaload
tableswitch { // 1 - 4
1: 3
2: 8
3: 5
4: 11
default: 13
}
3: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl top io.vertx.mqtt.impl.MqttClientImpl$Status top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
aload 4
monitorexit
4: areturn
5: StackMap locals:
StackMap stack:
aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSING:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
6: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
astore 1
start local 1 7: goto 14
end local 1 8: StackMap locals:
StackMap stack:
aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSING:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
9: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
astore 1
start local 1 10: goto 14
end local 1 11: StackMap locals:
StackMap stack:
aconst_null
astore 1
start local 1 12: goto 14
end local 1 13: StackMap locals:
StackMap stack:
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
start local 1 14: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.core.net.impl.NetSocketInternal io.vertx.mqtt.impl.MqttClientImpl$Status top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
astore 3
start local 3 15: aload 4
monitorexit
16: goto 19
end local 3 end local 2 end local 1 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl top top top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
17: aload 4
monitorexit
18: athrow
start local 1 start local 2 start local 3 19: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.core.net.impl.NetSocketInternal io.vertx.mqtt.impl.MqttClientImpl$Status io.vertx.core.Future
StackMap stack:
aload 1
ifnull 31
20: aload 2
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CONNECTED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
if_acmpne 30
21: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
22: getstatic io.netty.handler.codec.mqtt.MqttMessageType.DISCONNECT:Lio/netty/handler/codec/mqtt/MqttMessageType;
23: iconst_0
24: getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
25: iconst_0
26: iconst_0
27: invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
astore 4
start local 4 28: aload 4
aconst_null
aconst_null
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 5
start local 5 29: aload 1
aload 5
invokeinterface io.vertx.core.net.impl.NetSocketInternal.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/Future;
pop
end local 5 end local 4 30: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.net.impl.NetSocketInternal.close:()Lio/vertx/core/Future;
pop
31: StackMap locals:
StackMap stack:
aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 32 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
7 8 1 connection Lio/vertx/core/net/impl/NetSocketInternal;
10 11 1 connection Lio/vertx/core/net/impl/NetSocketInternal;
12 13 1 connection Lio/vertx/core/net/impl/NetSocketInternal;
14 17 1 connection Lio/vertx/core/net/impl/NetSocketInternal;
19 32 1 connection Lio/vertx/core/net/impl/NetSocketInternal;
2 17 2 status Lio/vertx/mqtt/impl/MqttClientImpl$Status;
19 32 2 status Lio/vertx/mqtt/impl/MqttClientImpl$Status;
15 17 3 fut Lio/vertx/core/Future<Ljava/lang/Void;>;
19 32 3 fut Lio/vertx/core/Future<Ljava/lang/Void;>;
28 30 4 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
29 30 5 disconnect Lio/netty/handler/codec/mqtt/MqttMessage;
Exception table:
from to target type
1 4 17 any
5 16 17 any
17 18 17 any
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.mqtt.MqttClient disconnect(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.disconnect:()Lio/vertx/core/Future;
astore 2
start local 2 1: aload 1
ifnull 3
2: aload 2
aload 1
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 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 disconnectHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 4 2 fut Lio/vertx/core/Future<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
disconnectHandler
public io.vertx.core.Future<java.lang.Integer> publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=11, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: getstatic io.netty.handler.codec.mqtt.MqttQoS.FAILURE:Lio/netty/handler/codec/mqtt/MqttQoS;
aload 3
if_acmpne 2
1: new java.lang.IllegalArgumentException
dup
ldc "QoS level must be one of AT_MOST_ONCE, AT_LEAST_ONCE or EXACTLY_ONCE"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
dup
astore 8
monitorenter
3: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getMaxInflightQueue:()I
if_icmplt 9
4: ldc "Attempt to exceed the limit of %d inflight messages"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getMaxInflightQueue:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 9
start local 9 5: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
aload 9
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
6: new io.vertx.mqtt.MqttException
dup
iconst_2
aload 9
invokespecial io.vertx.mqtt.MqttException.<init>:(ILjava/lang/String;)V
astore 10
start local 10 7: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
aload 10
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
aload 8
monitorexit
8: areturn
end local 10 end local 9 9: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String io.vertx.core.buffer.Buffer io.netty.handler.codec.mqtt.MqttQoS int int top top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.isValidTopicName:(Ljava/lang/String;)Z
ifne 15
10: ldc "Invalid Topic Name - %s. It mustn't contains wildcards: # and +. Also it can't contains U+0000(NULL) chars"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 9
start local 9 11: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
aload 9
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
12: new io.vertx.mqtt.MqttException
dup
iconst_0
aload 9
invokespecial io.vertx.mqtt.MqttException.<init>:(ILjava/lang/String;)V
astore 10
start local 10 13: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
aload 10
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
aload 8
monitorexit
14: areturn
end local 10 end local 9 15: StackMap locals:
StackMap stack:
new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
16: getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBLISH:Lio/netty/handler/codec/mqtt/MqttMessageType;
17: iload 4
18: aload 3
19: iload 5
20: iconst_0
21: invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
astore 9
start local 9 22: aload 2
invokeinterface io.vertx.core.buffer.Buffer.getBytes:()[B
invokestatic io.netty.buffer.Unpooled.copiedBuffer:([B)Lio/netty/buffer/ByteBuf;
astore 10
start local 10 23: new io.netty.handler.codec.mqtt.MqttPublishVariableHeader
dup
aload 1
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.nextMessageId:()I
invokespecial io.netty.handler.codec.mqtt.MqttPublishVariableHeader.<init>:(Ljava/lang/String;I)V
astore 7
start local 7 24: aload 9
aload 7
aload 10
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 6
start local 6 25: invokestatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS:()[I
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
iaload
tableswitch { // 2 - 3
2: 26
3: 29
default: 32
}
26: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String io.vertx.core.buffer.Buffer io.netty.handler.codec.mqtt.MqttQoS int int io.netty.handler.codec.mqtt.MqttMessage io.netty.handler.codec.mqtt.MqttPublishVariableHeader io.vertx.mqtt.impl.MqttClientImpl io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.buffer.ByteBuf
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos1outbound:Ljava/util/HashMap;
aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
new io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
dup
aload 0
aload 0
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;)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/MqttClientImpl.handlePubackTimeout(I)V (7)
(Ljava/lang/Integer;)V
aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
invokespecial io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.<init>:(Lio/vertx/mqtt/impl/MqttClientImpl;Lio/vertx/core/Handler;I)V
invokevirtual java.util.HashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
27: aload 0
dup
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
iconst_1
iadd
putfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
28: goto 32
29: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2outbound:Ljava/util/HashMap;
aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
new io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
dup
aload 0
aload 0
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;)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/MqttClientImpl.handlePubrecTimeout(I)V (7)
(Ljava/lang/Integer;)V
aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
invokespecial io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.<init>:(Lio/vertx/mqtt/impl/MqttClientImpl;Lio/vertx/core/Handler;I)V
invokevirtual java.util.HashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
30: aload 0
dup
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
iconst_1
iadd
putfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
31: goto 32
end local 10 end local 9 32: StackMap locals:
StackMap stack:
aload 8
monitorexit
33: goto 36
end local 7 end local 6 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String io.vertx.core.buffer.Buffer io.netty.handler.codec.mqtt.MqttQoS int int top top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
34: aload 8
monitorexit
35: athrow
start local 6 start local 7 36: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String io.vertx.core.buffer.Buffer io.netty.handler.codec.mqtt.MqttQoS int int io.netty.handler.codec.mqtt.MqttMessage io.netty.handler.codec.mqtt.MqttPublishVariableHeader
StackMap stack:
aload 0
aload 6
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 37 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 37 1 topic Ljava/lang/String;
0 37 2 payload Lio/vertx/core/buffer/Buffer;
0 37 3 qosLevel Lio/netty/handler/codec/mqtt/MqttQoS;
0 37 4 isDup Z
0 37 5 isRetain Z
25 34 6 publish Lio/netty/handler/codec/mqtt/MqttMessage;
36 37 6 publish Lio/netty/handler/codec/mqtt/MqttMessage;
24 34 7 variableHeader Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
36 37 7 variableHeader Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
5 9 9 msg Ljava/lang/String;
7 9 10 exception Lio/vertx/mqtt/MqttException;
11 15 9 msg Ljava/lang/String;
13 15 10 exception Lio/vertx/mqtt/MqttException;
22 32 9 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
23 32 10 buf Lio/netty/buffer/ByteBuf;
Exception table:
from to target type
3 8 34 any
9 14 34 any
15 33 34 any
34 35 34 any
Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)Lio/vertx/core/Future<Ljava/lang/Integer;>;
MethodParameters:
Name Flags
topic
payload
qosLevel
isDup
isRetain
public io.vertx.mqtt.MqttClient publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=8, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
aload 1
aload 2
aload 3
iload 4
iload 5
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publish:(Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)Lio/vertx/core/Future;
astore 7
start local 7 1: aload 6
ifnull 3
2: aload 7
aload 6
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 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 topic Ljava/lang/String;
0 4 2 payload Lio/vertx/core/buffer/Buffer;
0 4 3 qosLevel Lio/netty/handler/codec/mqtt/MqttQoS;
0 4 4 isDup Z
0 4 5 isRetain Z
0 4 6 publishSentHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
1 4 7 fut Lio/vertx/core/Future<Ljava/lang/Integer;>;
Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
topic
payload
qosLevel
isDup
isRetain
publishSentHandler
public io.vertx.mqtt.MqttClient publishCompletionHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.mqtt.impl.MqttClientImpl.publishCompletionHandler: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/MqttClientImpl;
0 2 1 publishCompletionHandler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
publishCompletionHandler
private synchronized io.vertx.core.Handler<java.lang.Integer> publishCompletionHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.publishCompletionHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Integer;>;
public io.vertx.mqtt.MqttClient publishCompletionExpirationHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.mqtt.impl.MqttClientImpl.publishCompletionExpirationHandler: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/MqttClientImpl;
0 2 1 publishCompletionExpirationHandler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
publishCompletionExpirationHandler
private synchronized io.vertx.core.Handler<java.lang.Integer> publishCompletionExpirationHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.publishCompletionExpirationHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Integer;>;
public io.vertx.mqtt.MqttClient publishCompletionUnknownPacketIdHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.mqtt.impl.MqttClientImpl.publishCompletionPhantomHandler: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/MqttClientImpl;
0 2 1 publishCompletionPhantomHandler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
publishCompletionPhantomHandler
private synchronized io.vertx.core.Handler<java.lang.Integer> publishCompletionUnknownPacketIdHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.publishCompletionPhantomHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Integer;>;
public io.vertx.mqtt.MqttClient publishHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttPublishMessage>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.mqtt.impl.MqttClientImpl.publishHandler: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/MqttClientImpl;
0 2 1 publishHandler Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
publishHandler
private synchronized io.vertx.core.Handler<io.vertx.mqtt.messages.MqttPublishMessage> publishHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.publishHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;
public io.vertx.mqtt.MqttClient subscribeCompletionHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttSubAckMessage>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.mqtt.impl.MqttClientImpl.subscribeCompletionHandler: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/MqttClientImpl;
0 2 1 subscribeCompletionHandler Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubAckMessage;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubAckMessage;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
subscribeCompletionHandler
private synchronized io.vertx.core.Handler<io.vertx.mqtt.messages.MqttSubAckMessage> subscribeCompletionHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.subscribeCompletionHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubAckMessage;>;
public io.vertx.core.Future<java.lang.Integer> subscribe(java.lang.String, int);
descriptor: (Ljava/lang/String;I)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.subscribe:(Ljava/util/Map;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 1 1 topic Ljava/lang/String;
0 1 2 qos I
Signature: (Ljava/lang/String;I)Lio/vertx/core/Future<Ljava/lang/Integer;>;
MethodParameters:
Name Flags
topic
qos
public io.vertx.mqtt.MqttClient subscribe(java.lang.String, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
descriptor: (Ljava/lang/String;ILio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
aload 3
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.subscribe:(Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 1 1 topic Ljava/lang/String;
0 1 2 qos I
0 1 3 subscribeSentHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
Signature: (Ljava/lang/String;ILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
topic
qos
subscribeSentHandler
public io.vertx.core.Future<java.lang.Integer> subscribe(java.util.Map<java.lang.String, java.lang.Integer>);
descriptor: (Ljava/util/Map;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
1: invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
2: aload 0
invokedynamic test(Lio/vertx/mqtt/impl/MqttClientImpl;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
io/vertx/mqtt/impl/MqttClientImpl.lambda$7(Ljava/util/Map$Entry;)Z (7)
(Ljava/util/Map$Entry;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
3: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/util/Map$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/String;
invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/util/Map$Entry.getValue()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/Integer;
invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
4: astore 2
start local 2 5: aload 2
invokeinterface java.util.Map.size:()I
ifle 10
6: ldc "Invalid Topic Filters: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 2
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 3
start local 3 7: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
aload 3
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
8: new io.vertx.mqtt.MqttException
dup
iconst_1
aload 3
invokespecial io.vertx.mqtt.MqttException.<init>:(ILjava/lang/String;)V
astore 4
start local 4 9: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
aload 4
invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
areturn
end local 4 end local 3 10: StackMap locals: java.util.Map
StackMap stack:
new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
11: getstatic io.netty.handler.codec.mqtt.MqttMessageType.SUBSCRIBE:Lio/netty/handler/codec/mqtt/MqttMessageType;
12: iconst_0
13: getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_LEAST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
14: iconst_0
15: iconst_0
16: invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
astore 3
start local 3 17: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.nextMessageId:()I
invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
astore 4
start local 4 18: aload 1
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
19: invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
20: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/mqtt/impl/MqttClientImpl.lambda$10(Ljava/util/Map$Entry;)Lio/netty/handler/codec/mqtt/MqttTopicSubscription; (6)
(Ljava/util/Map$Entry;)Lio/netty/handler/codec/mqtt/MqttTopicSubscription;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
21: invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
22: astore 5
start local 5 23: new io.netty.handler.codec.mqtt.MqttSubscribePayload
dup
aload 5
invokespecial io.netty.handler.codec.mqtt.MqttSubscribePayload.<init>:(Ljava/util/List;)V
astore 6
start local 6 24: aload 3
aload 4
aload 6
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 7
start local 7 25: aload 0
aload 7
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
aload 4
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 26 1 topics Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>;
5 26 2 invalidTopics Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>;
7 10 3 msg Ljava/lang/String;
9 10 4 exception Lio/vertx/mqtt/MqttException;
17 26 3 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
18 26 4 variableHeader Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
23 26 5 subscriptions Ljava/util/List<Lio/netty/handler/codec/mqtt/MqttTopicSubscription;>;
24 26 6 payload Lio/netty/handler/codec/mqtt/MqttSubscribePayload;
25 26 7 subscribe Lio/netty/handler/codec/mqtt/MqttMessage;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>;)Lio/vertx/core/Future<Ljava/lang/Integer;>;
MethodParameters:
Name Flags
topics
public io.vertx.mqtt.MqttClient subscribe(java.util.Map<java.lang.String, java.lang.Integer>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
descriptor: (Ljava/util/Map;Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.subscribe:(Ljava/util/Map;)Lio/vertx/core/Future;
astore 3
start local 3 1: aload 2
ifnull 3
2: aload 3
aload 2
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 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 topics Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>;
0 4 2 subscribeSentHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
1 4 3 fut Lio/vertx/core/Future<Ljava/lang/Integer;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
topics
subscribeSentHandler
public io.vertx.mqtt.MqttClient unsubscribeCompletionHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.mqtt.impl.MqttClientImpl.unsubscribeCompletionHandler: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/MqttClientImpl;
0 2 1 unsubscribeCompletionHandler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
unsubscribeCompletionHandler
private synchronized io.vertx.core.Handler<java.lang.Integer> unsubscribeCompletionHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.unsubscribeCompletionHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Integer;>;
public io.vertx.mqtt.MqttClient unsubscribe(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.unsubscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
astore 3
start local 3 1: aload 2
ifnull 3
2: aload 3
aload 2
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 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 topic Ljava/lang/String;
0 4 2 unsubscribeSentHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
1 4 3 fut Lio/vertx/core/Future<Ljava/lang/Integer;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
topic
unsubscribeSentHandler
public io.vertx.core.Future<java.lang.Integer> unsubscribe(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=2
start local 0 start local 1 0: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
1: getstatic io.netty.handler.codec.mqtt.MqttMessageType.UNSUBSCRIBE:Lio/netty/handler/codec/mqtt/MqttMessageType;
2: iconst_0
3: getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_LEAST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
4: iconst_0
5: iconst_0
6: invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
astore 2
start local 2 7: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.nextMessageId:()I
invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
astore 3
start local 3 8: new io.netty.handler.codec.mqtt.MqttUnsubscribePayload
dup
aload 1
invokestatic java.util.stream.Stream.of:(Ljava/lang/Object;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
invokespecial io.netty.handler.codec.mqtt.MqttUnsubscribePayload.<init>:(Ljava/util/List;)V
astore 4
start local 4 9: aload 2
aload 3
aload 4
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 5
start local 5 10: aload 0
aload 5
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
pop
11: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 12 1 topic Ljava/lang/String;
7 12 2 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
8 12 3 variableHeader Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
9 12 4 payload Lio/netty/handler/codec/mqtt/MqttUnsubscribePayload;
10 12 5 unsubscribe Lio/netty/handler/codec/mqtt/MqttMessage;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/lang/Integer;>;
MethodParameters:
Name Flags
topic
public synchronized io.vertx.mqtt.MqttClient pingResponseHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
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.MqttClientImpl.pingrespHandler: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/MqttClientImpl;
0 2 1 pingResponseHandler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
pingResponseHandler
private synchronized io.vertx.core.Handler<java.lang.Void> pingResponseHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.pingrespHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Void;>;
public synchronized io.vertx.mqtt.MqttClient exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
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.MqttClientImpl.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/MqttClientImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
handler
private synchronized io.vertx.core.Handler<java.lang.Throwable> exceptionHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.exceptionHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
public synchronized io.vertx.mqtt.MqttClient closeHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttClient;
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.MqttClientImpl.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/mqtt/impl/MqttClientImpl;
0 2 1 closeHandler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/MqttClient;
MethodParameters:
Name Flags
closeHandler
private synchronized io.vertx.core.Handler<java.lang.Void> closeHandler();
descriptor: ()Lio/vertx/core/Handler;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.closeHandler:Lio/vertx/core/Handler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
Signature: ()Lio/vertx/core/Handler<Ljava/lang/Void;>;
public io.vertx.mqtt.MqttClient ping();
descriptor: ()Lio/vertx/mqtt/MqttClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=1
start local 0 0: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
if_acmpne 8
1: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PINGREQ:Lio/netty/handler/codec/mqtt/MqttMessageType;
iconst_0
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
iconst_0
iconst_0
invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
2: astore 1
start local 1 3: aload 1
aconst_null
aconst_null
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 2
start local 2 4: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.keepAliveTimeout:J
aload 0
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;)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/MqttClientImpl.lambda$11(Ljava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.impl.VertxInternal.setTimer:(JLio/vertx/core/Handler;)J
lstore 3
start local 3 5: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.pings:Ljava/util/Deque;
new io.vertx.mqtt.impl.MqttClientImpl$Ping
dup
aload 0
lload 3
invokespecial io.vertx.mqtt.impl.MqttClientImpl$Ping.<init>:(Lio/vertx/mqtt/impl/MqttClientImpl;J)V
invokeinterface java.util.Deque.add:(Ljava/lang/Object;)Z
pop
6: aload 0
aload 2
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
pop
end local 3 end local 2 end local 1 7: goto 9
8: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
aload 0
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;)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/MqttClientImpl.lambda$12(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)V
9: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
3 7 1 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
4 7 2 pingreq Lio/netty/handler/codec/mqtt/MqttMessage;
5 7 3 id J
public synchronized java.lang.String clientId();
descriptor: ()Ljava/lang/String;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getClientId:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
public synchronized boolean isConnected();
descriptor: ()Z
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CONNECTED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
private void publishAcknowledge(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=5, args_size=2
start local 0 start local 1 0: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
iconst_0
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
iconst_0
iconst_0
invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
1: astore 2
start local 2 2: iload 1
invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
3: astore 3
start local 3 4: aload 2
aload 3
aconst_null
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 4
start local 4 5: aload 0
aload 4
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
pop
6: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 7 1 publishMessageId I
2 7 2 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
4 7 3 variableHeader Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
5 7 4 puback Lio/netty/handler/codec/mqtt/MqttMessage;
MethodParameters:
Name Flags
publishMessageId
private void publishReceived(io.vertx.mqtt.messages.MqttPublishMessage);
descriptor: (Lio/vertx/mqtt/messages/MqttPublishMessage;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=6, args_size=2
start local 0 start local 1 0: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREC:Lio/netty/handler/codec/mqtt/MqttMessageType;
iconst_0
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
iconst_0
iconst_0
invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
1: astore 2
start local 2 2: aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.messageId:()I
invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
3: astore 3
start local 3 4: aload 2
aload 3
aconst_null
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 4
start local 4 5: aload 0
dup
astore 5
monitorenter
6: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2inbound:Ljava/util/HashMap;
aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.messageId:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aload 1
invokevirtual java.util.HashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 5
monitorexit
8: goto 11
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.messages.MqttPublishMessage io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader io.netty.handler.codec.mqtt.MqttMessage io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
9: aload 5
monitorexit
10: athrow
11: StackMap locals:
StackMap stack:
aload 0
aload 4
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
pop
12: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 13 1 publishMessage Lio/vertx/mqtt/messages/MqttPublishMessage;
2 13 2 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
4 13 3 variableHeader Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
5 13 4 pubrec Lio/netty/handler/codec/mqtt/MqttMessage;
Exception table:
from to target type
6 8 9 any
9 10 9 any
MethodParameters:
Name Flags
publishMessage
private void publishComplete(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=5, args_size=2
start local 0 start local 1 0: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBCOMP:Lio/netty/handler/codec/mqtt/MqttMessageType;
iconst_0
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
iconst_0
iconst_0
invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
1: astore 2
start local 2 2: iload 1
invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
3: astore 3
start local 3 4: aload 2
aload 3
aconst_null
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 4
start local 4 5: aload 0
aload 4
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
pop
6: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 7 1 publishMessageId I
2 7 2 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
4 7 3 variableHeader Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
5 7 4 pubcomp Lio/netty/handler/codec/mqtt/MqttMessage;
MethodParameters:
Name Flags
publishMessageId
private void publishRelease(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=6, args_size=2
start local 0 start local 1 0: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREL:Lio/netty/handler/codec/mqtt/MqttMessageType;
iconst_0
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_LEAST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
iconst_0
iconst_0
invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
1: astore 2
start local 2 2: iload 1
invokestatic io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.from:(I)Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
3: astore 3
start local 3 4: aload 2
aload 3
aconst_null
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 4
start local 4 5: aload 0
dup
astore 5
monitorenter
6: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2outbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
new io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
dup
aload 0
aload 0
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;)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/MqttClientImpl.handlePubcompTimeout(I)V (7)
(Ljava/lang/Integer;)V
iload 1
invokespecial io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.<init>:(Lio/vertx/mqtt/impl/MqttClientImpl;Lio/vertx/core/Handler;I)V
invokevirtual java.util.HashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 5
monitorexit
8: goto 11
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader io.netty.handler.codec.mqtt.MqttMessage io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
9: aload 5
monitorexit
10: athrow
11: StackMap locals:
StackMap stack:
aload 0
aload 4
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
pop
12: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 13 1 publishMessageId I
2 13 2 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
4 13 3 variableHeader Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
5 13 4 pubrel Lio/netty/handler/codec/mqtt/MqttMessage;
Exception table:
from to target type
6 8 9 any
9 10 9 any
MethodParameters:
Name Flags
publishMessageId
private void initChannel(io.vertx.core.net.impl.NetSocketInternal);
descriptor: (Lio/vertx/core/net/impl/NetSocketInternal;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 2
start local 2 1: aload 2
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
2: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getMaxMessageSize:()I
ifle 5
3: aload 2
ldc "handler"
ldc "mqttDecoder"
new io.netty.handler.codec.mqtt.MqttDecoder
dup
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.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
4: goto 6
5: StackMap locals: io.netty.channel.ChannelPipeline
StackMap stack:
aload 2
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
6: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.isAutoKeepAlive:()Z
ifeq 12
7: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getKeepAliveInterval:()I
ifeq 12
8: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getKeepAliveInterval:()I
istore 3
start local 3 9: aload 2
ldc "handler"
ldc "idle"
10: new io.vertx.mqtt.impl.MqttClientImpl$1
dup
aload 0
iconst_0
iconst_0
iload 3
invokespecial io.vertx.mqtt.impl.MqttClientImpl$1.<init>:(Lio/vertx/mqtt/impl/MqttClientImpl;III)V
11: invokeinterface io.netty.channel.ChannelPipeline.addBefore:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
end local 3 12: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 13 1 sock Lio/vertx/core/net/impl/NetSocketInternal;
1 13 2 pipeline Lio/netty/channel/ChannelPipeline;
9 12 3 keepAliveInterval I
MethodParameters:
Name Flags
sock
private synchronized int nextMessageId();
descriptor: ()I
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.messageIdCounter:I
ldc 65535
irem
ifeq 1
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.messageIdCounter:I
iconst_1
iadd
goto 2
StackMap locals:
StackMap stack: io.vertx.mqtt.impl.MqttClientImpl
1: iconst_1
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: io.vertx.mqtt.impl.MqttClientImpl int
2: putfield io.vertx.mqtt.impl.MqttClientImpl.messageIdCounter:I
3: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.messageIdCounter:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
private synchronized io.vertx.core.net.impl.NetSocketInternal connection();
descriptor: ()Lio/vertx/core/net/impl/NetSocketInternal;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
private io.vertx.core.Future<java.lang.Void> write(io.netty.handler.codec.mqtt.MqttMessage);
descriptor: (Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Sending packet %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
1: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.connection:()Lio/vertx/core/net/impl/NetSocketInternal;
aload 1
invokeinterface io.vertx.core.net.impl.NetSocketInternal.writeMessage:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 2 1 mqttMessage Lio/netty/handler/codec/mqtt/MqttMessage;
Signature: (Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
mqttMessage
private void handleClosed();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=6, args_size=1
start local 0 0: aload 0
dup
astore 5
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.client:Lio/vertx/core/net/NetClient;
astore 3
start local 3 2: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
astore 1
start local 1 3: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
astore 2
start local 2 4: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.pings:Ljava/util/Deque;
astore 4
start local 4 5: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
6: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
7: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
8: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
9: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.client:Lio/vertx/core/net/NetClient;
10: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield io.vertx.mqtt.impl.MqttClientImpl.pings:Ljava/util/Deque;
11: aload 5
monitorexit
12: goto 15
end local 4 end local 3 end local 2 end local 1 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl top top top top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
13: aload 5
monitorexit
14: athrow
start local 1 start local 2 start local 3 start local 4 15: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.core.Promise io.vertx.core.Promise io.vertx.core.net.NetClient java.util.Deque
StackMap stack:
aload 4
invokedynamic accept()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/mqtt/impl/MqttClientImpl.lambda$14(Lio/vertx/mqtt/impl/MqttClientImpl$Ping;)V (6)
(Lio/vertx/mqtt/impl/MqttClientImpl$Ping;)V
invokeinterface java.util.Deque.forEach:(Ljava/util/function/Consumer;)V
16: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.closeHandler:()Lio/vertx/core/Handler;
astore 5
start local 5 17: aload 5
ifnull 19
18: aload 5
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
19: StackMap locals: io.vertx.core.Handler
StackMap stack:
aload 2
invokeinterface io.vertx.core.Promise.complete:()V
20: aload 1
ifnull 22
21: aload 1
ldc "Closed"
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
22: StackMap locals:
StackMap stack:
aload 3
invokeinterface io.vertx.core.net.NetClient.close:()Lio/vertx/core/Future;
pop
23: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
3 13 1 connectPromise Lio/vertx/core/Promise<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
15 24 1 connectPromise Lio/vertx/core/Promise<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
4 13 2 disconnectPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
15 24 2 disconnectPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
2 13 3 client Lio/vertx/core/net/NetClient;
15 24 3 client Lio/vertx/core/net/NetClient;
5 13 4 pings Ljava/util/Deque<Lio/vertx/mqtt/impl/MqttClientImpl$Ping;>;
15 24 4 pings Ljava/util/Deque<Lio/vertx/mqtt/impl/MqttClientImpl$Ping;>;
17 24 5 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Exception table:
from to target type
1 12 13 any
13 14 13 any
private void handleMessage(io.netty.channel.ChannelHandlerContext, java.lang.Object);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=12, args_size=3
start local 0 start local 1 start local 2 0: aload 2
instanceof io.netty.handler.codec.mqtt.MqttMessage
ifeq 48
1: aload 2
checkcast io.netty.handler.codec.mqtt.MqttMessage
astore 3
start local 3 2: aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessage.decoderResult:()Lio/netty/handler/codec/DecoderResult;
astore 4
start local 4 3: aload 4
invokevirtual io.netty.handler.codec.DecoderResult.isFailure:()Z
ifeq 6
4: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
aload 4
invokevirtual io.netty.handler.codec.DecoderResult.cause:()Ljava/lang/Throwable;
invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
pop
5: return
6: StackMap locals: io.netty.handler.codec.mqtt.MqttMessage io.netty.handler.codec.DecoderResult
StackMap stack:
aload 4
invokevirtual io.netty.handler.codec.DecoderResult.isFinished:()Z
ifne 9
7: aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
new java.lang.Exception
dup
ldc "Unfinished message"
invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
pop
8: return
9: StackMap locals:
StackMap stack:
getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Incoming packet %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 2
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
10: invokestatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:()[I
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.messageType:()Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
iaload
tableswitch { // 2 - 13
2: 11
3: 17
4: 28
5: 30
6: 32
7: 34
8: 46
9: 36
10: 46
11: 42
12: 46
13: 44
default: 46
}
11: StackMap locals:
StackMap stack:
aload 3
checkcast io.netty.handler.codec.mqtt.MqttConnAckMessage
astore 5
start local 5 12: aload 5
invokevirtual io.netty.handler.codec.mqtt.MqttConnAckMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnAckVariableHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttConnAckVariableHeader.connectReturnCode:()Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
13: aload 5
invokevirtual io.netty.handler.codec.mqtt.MqttConnAckMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttConnAckVariableHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttConnAckVariableHeader.isSessionPresent:()Z
14: invokestatic io.vertx.mqtt.messages.MqttConnAckMessage.create:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;Z)Lio/vertx/mqtt/messages/MqttConnAckMessage;
astore 6
start local 6 15: aload 0
aload 6
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handleConnack:(Lio/vertx/mqtt/messages/MqttConnAckMessage;)V
16: goto 49
end local 6 end local 5 17: StackMap locals:
StackMap stack:
aload 3
checkcast io.netty.handler.codec.mqtt.MqttPublishMessage
astore 7
start local 7 18: aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.payload:()Lio/netty/buffer/ByteBuf;
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
invokestatic io.vertx.core.net.impl.VertxHandler.safeBuffer:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
astore 8
start local 8 19: aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.packetId:()I
20: aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
21: aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.isDup:()Z
22: aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.fixedHeader:()Lio/netty/handler/codec/mqtt/MqttFixedHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttFixedHeader.isRetain:()Z
23: aload 7
invokevirtual io.netty.handler.codec.mqtt.MqttPublishMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttPublishVariableHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttPublishVariableHeader.topicName:()Ljava/lang/String;
24: aload 8
25: invokestatic io.vertx.mqtt.messages.MqttPublishMessage.create:(ILio/netty/handler/codec/mqtt/MqttQoS;ZZLjava/lang/String;Lio/netty/buffer/ByteBuf;)Lio/vertx/mqtt/messages/MqttPublishMessage;
astore 9
start local 9 26: aload 0
aload 9
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handlePublish:(Lio/vertx/mqtt/messages/MqttPublishMessage;)V
27: goto 49
end local 9 end local 8 end local 7 28: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handlePuback:(I)V
29: goto 49
30: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handlePubrec:(I)V
31: goto 49
32: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handlePubrel:(I)V
33: goto 49
34: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handlePubcomp:(I)V
35: goto 49
36: StackMap locals:
StackMap stack:
aload 3
checkcast io.netty.handler.codec.mqtt.MqttSubAckMessage
astore 10
start local 10 37: aload 10
invokevirtual io.netty.handler.codec.mqtt.MqttSubAckMessage.variableHeader:()Lio/netty/handler/codec/mqtt/MqttMessageIdVariableHeader;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
38: aload 10
invokevirtual io.netty.handler.codec.mqtt.MqttSubAckMessage.payload:()Lio/netty/handler/codec/mqtt/MqttSubAckPayload;
invokevirtual io.netty.handler.codec.mqtt.MqttSubAckPayload.grantedQoSLevels:()Ljava/util/List;
39: invokestatic io.vertx.mqtt.messages.MqttSubAckMessage.create:(ILjava/util/List;)Lio/vertx/mqtt/messages/MqttSubAckMessage;
astore 11
start local 11 40: aload 0
aload 11
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handleSuback:(Lio/vertx/mqtt/messages/MqttSubAckMessage;)V
41: goto 49
end local 11 end local 10 42: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual io.netty.handler.codec.mqtt.MqttMessage.variableHeader:()Ljava/lang/Object;
checkcast io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader
invokevirtual io.netty.handler.codec.mqtt.MqttMessageIdVariableHeader.messageId:()I
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handleUnsuback:(I)V
43: goto 49
44: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handlePingresp:()V
45: goto 49
46: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
new java.lang.Exception
dup
new java.lang.StringBuilder
dup
ldc "Wrong message type "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
pop
end local 4 end local 3 47: goto 49
48: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
new java.lang.Exception
dup
ldc "Wrong message type"
invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
invokeinterface io.netty.channel.ChannelPipeline.fireExceptionCaught:(Ljava/lang/Throwable;)Lio/netty/channel/ChannelPipeline;
pop
49: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 50 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 50 1 chctx Lio/netty/channel/ChannelHandlerContext;
0 50 2 msg Ljava/lang/Object;
2 47 3 mqttMessage Lio/netty/handler/codec/mqtt/MqttMessage;
3 47 4 result Lio/netty/handler/codec/DecoderResult;
12 17 5 connack Lio/netty/handler/codec/mqtt/MqttConnAckMessage;
15 17 6 mqttConnAckMessage Lio/vertx/mqtt/messages/MqttConnAckMessage;
18 28 7 publish Lio/netty/handler/codec/mqtt/MqttPublishMessage;
19 28 8 newBuf Lio/netty/buffer/ByteBuf;
26 28 9 mqttPublishMessage Lio/vertx/mqtt/messages/MqttPublishMessage;
37 42 10 unsuback Lio/netty/handler/codec/mqtt/MqttSubAckMessage;
40 42 11 mqttSubAckMessage Lio/vertx/mqtt/messages/MqttSubAckMessage;
MethodParameters:
Name Flags
chctx
msg
private void handlePingresp();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.pings:Ljava/util/Deque;
invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
checkcast io.vertx.mqtt.impl.MqttClientImpl$Ping
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Ping.ack:()V
3: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl$Ping
StackMap stack:
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.pingResponseHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 4: aload 2
ifnull 6
5: aload 2
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
1 7 1 ping Lio/vertx/mqtt/impl/MqttClientImpl$Ping;
4 7 2 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
private void handleUnsuback(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.unsubscribeCompletionHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 1: aload 2
ifnull 3
2: aload 2
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 unsubackMessageId I
1 4 2 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
MethodParameters:
Name Flags
unsubackMessageId
private void handlePuback(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos1outbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.HashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
astore 3
start local 3 2: aload 3
ifnonnull 9
3: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Received PUBACK packet without having related PUBLISH packet in storage"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
4: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionUnknownPacketIdHandler:()Lio/vertx/core/Handler;
astore 4
start local 4 5: aload 4
ifnull 7
6: aload 4
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket io.vertx.core.Handler
StackMap stack:
aload 2
monitorexit
8: return
end local 4 9: StackMap locals:
StackMap stack:
aload 3
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.cancelTimer:()Z
pop
10: aload 0
dup
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
iconst_1
isub
putfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
end local 3 11: aload 2
monitorexit
12: goto 15
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
13: aload 2
monitorexit
14: athrow
15: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 16: aload 2
ifnull 18
17: aload 2
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
18: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 19 1 pubackMessageId I
2 11 3 removedPacket Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
5 9 4 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
16 19 2 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Exception table:
from to target type
1 8 13 any
9 12 13 any
13 14 13 any
MethodParameters:
Name Flags
pubackMessageId
private void handlePubackTimeout(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos1outbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.HashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
astore 2
start local 2 2: aload 2
ifnonnull 6
3: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "PUBLISH expiration timer fired but QoS 1 message has already been PUBACKed by server"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
4: aload 3
monitorexit
5: return
6: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 3
monitorexit
7: goto 10
end local 2 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
8: aload 3
monitorexit
9: athrow
start local 2 10: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
StackMap stack:
aload 0
dup
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
iconst_1
isub
putfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
11: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionExpirationHandler:()Lio/vertx/core/Handler;
astore 3
start local 3 12: aload 3
ifnull 14
13: aload 3
aload 2
getfield io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.packetId:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
14: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 15 1 packetId I
2 8 2 expiredMessage Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
10 15 2 expiredMessage Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
12 15 3 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Exception table:
from to target type
1 5 8 any
6 7 8 any
8 9 8 any
MethodParameters:
Name Flags
packetId
private void handlePubcomp(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2outbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.HashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
astore 3
start local 3 2: aload 3
ifnonnull 9
3: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Received PUBCOMP packet without having related PUBREL packet in storage"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
4: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionUnknownPacketIdHandler:()Lio/vertx/core/Handler;
astore 4
start local 4 5: aload 4
ifnull 7
6: aload 4
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket io.vertx.core.Handler
StackMap stack:
aload 2
monitorexit
8: return
end local 4 9: StackMap locals:
StackMap stack:
aload 3
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.cancelTimer:()Z
pop
10: aload 0
dup
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
iconst_1
isub
putfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
end local 3 11: aload 2
monitorexit
12: goto 15
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
13: aload 2
monitorexit
14: athrow
15: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 16: aload 2
ifnull 18
17: aload 2
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
18: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 19 1 pubcompMessageId I
2 11 3 removedPacket Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
5 9 4 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
16 19 2 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Exception table:
from to target type
1 8 13 any
9 12 13 any
13 14 13 any
MethodParameters:
Name Flags
pubcompMessageId
private void handlePubcompTimeout(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2outbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.HashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
astore 2
start local 2 2: aload 2
ifnonnull 6
3: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "PUBCOMP expiration timer fired but QoS 2 message has already been PUBCOMPed by server"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
4: aload 3
monitorexit
5: return
6: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 3
monitorexit
7: goto 10
end local 2 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
8: aload 3
monitorexit
9: athrow
start local 2 10: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
StackMap stack:
aload 0
dup
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
iconst_1
isub
putfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
11: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionExpirationHandler:()Lio/vertx/core/Handler;
astore 3
start local 3 12: aload 3
ifnull 14
13: aload 3
aload 2
getfield io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.packetId:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
14: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 15 1 packetId I
2 8 2 expiredMessage Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
10 15 2 expiredMessage Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
12 15 3 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Exception table:
from to target type
1 5 8 any
6 7 8 any
8 9 8 any
MethodParameters:
Name Flags
packetId
private void handlePubrec(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2outbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.HashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
astore 3
start local 3 2: aload 3
ifnonnull 9
3: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Received PUBREC packet without having related PUBLISH packet in storage"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
4: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionUnknownPacketIdHandler:()Lio/vertx/core/Handler;
astore 4
start local 4 5: aload 4
ifnull 7
6: aload 4
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket io.vertx.core.Handler
StackMap stack:
aload 2
monitorexit
8: return
end local 4 9: StackMap locals:
StackMap stack:
aload 3
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.cancelTimer:()Z
pop
end local 3 10: aload 2
monitorexit
11: goto 14
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
12: aload 2
monitorexit
13: athrow
14: StackMap locals:
StackMap stack:
aload 0
iload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishRelease:(I)V
15: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 16 1 pubrecMessageId I
2 10 3 removedPacket Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
5 9 4 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Exception table:
from to target type
1 8 12 any
9 11 12 any
12 13 12 any
MethodParameters:
Name Flags
pubrecMessageId
private void handlePubrecTimeout(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2outbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.HashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
astore 2
start local 2 2: aload 2
ifnonnull 6
3: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "PUBREC expiration timer fired but QoS 2 message has already been PUBRECed by server"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
4: aload 3
monitorexit
5: return
6: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 3
monitorexit
7: goto 10
end local 2 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
8: aload 3
monitorexit
9: athrow
start local 2 10: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket
StackMap stack:
aload 0
dup
getfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
iconst_1
isub
putfield io.vertx.mqtt.impl.MqttClientImpl.countInflightQueue:I
11: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishCompletionExpirationHandler:()Lio/vertx/core/Handler;
astore 3
start local 3 12: aload 3
ifnull 14
13: aload 3
aload 2
getfield io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket.packetId:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
14: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 15 1 packetId I
2 8 2 expiredMessage Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
10 15 2 expiredMessage Lio/vertx/mqtt/impl/MqttClientImpl$ExpiringPacket;
12 15 3 handler Lio/vertx/core/Handler<Ljava/lang/Integer;>;
Exception table:
from to target type
1 5 8 any
6 7 8 any
8 9 8 any
MethodParameters:
Name Flags
packetId
private void handleSuback(io.vertx.mqtt.messages.MqttSubAckMessage);
descriptor: (Lio/vertx/mqtt/messages/MqttSubAckMessage;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.subscribeCompletionHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 1: aload 2
ifnull 3
2: aload 2
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 msg Lio/vertx/mqtt/messages/MqttSubAckMessage;
1 4 2 handler Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubAckMessage;>;
MethodParameters:
Name Flags
msg
private void handlePublish(io.vertx.mqtt.messages.MqttPublishMessage);
descriptor: (Lio/vertx/mqtt/messages/MqttPublishMessage;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS:()[I
aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.qosLevel:()Lio/netty/handler/codec/mqtt/MqttQoS;
invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
iaload
tableswitch { // 1 - 3
1: 1
2: 5
3: 10
default: 11
}
1: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 2: aload 2
ifnull 11
3: aload 2
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: goto 11
end local 2 5: StackMap locals:
StackMap stack:
aload 0
aload 1
invokeinterface io.vertx.mqtt.messages.MqttPublishMessage.messageId:()I
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishAcknowledge:(I)V
6: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 7: aload 2
ifnull 11
8: aload 2
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
9: goto 11
end local 2 10: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishReceived:(Lio/vertx/mqtt/messages/MqttPublishMessage;)V
11: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 12 1 msg Lio/vertx/mqtt/messages/MqttPublishMessage;
2 5 2 handler Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;
7 10 2 handler Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;
MethodParameters:
Name Flags
msg
private void handlePubrel(int);
descriptor: (I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.qos2inbound:Ljava/util/HashMap;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.HashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.mqtt.messages.MqttMessage
astore 2
start local 2 2: aload 2
ifnonnull 6
3: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Received PUBREL packet without having related PUBREC packet in storage"
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
4: aload 3
monitorexit
5: return
6: StackMap locals: io.vertx.mqtt.messages.MqttMessage io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 0
iload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishComplete:(I)V
7: aload 3
monitorexit
8: goto 11
end local 2 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
9: aload 3
monitorexit
10: athrow
start local 2 11: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl int io.vertx.mqtt.messages.MqttMessage
StackMap stack:
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.publishHandler:()Lio/vertx/core/Handler;
astore 3
start local 3 12: aload 3
ifnull 14
13: aload 3
aload 2
checkcast io.vertx.mqtt.messages.MqttPublishMessage
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
14: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 15 1 pubrelMessageId I
2 9 2 message Lio/vertx/mqtt/messages/MqttMessage;
11 15 2 message Lio/vertx/mqtt/messages/MqttMessage;
12 15 3 handler Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;
Exception table:
from to target type
1 5 9 any
6 8 9 any
9 10 9 any
MethodParameters:
Name Flags
pubrelMessageId
private void handleConnack(io.vertx.mqtt.messages.MqttConnAckMessage);
descriptor: (Lio/vertx/mqtt/messages/MqttConnAckMessage;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=7, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.mqtt.messages.MqttConnAckMessage.code:()Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_ACCEPTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
if_acmpne 1
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CONNECTED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
pop
goto 2
StackMap locals:
StackMap stack:
1: getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSING:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
pop
2: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.mqtt.messages.MqttConnAckMessage.code:()Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
getstatic io.netty.handler.codec.mqtt.MqttConnectReturnCode.CONNECTION_ACCEPTED:Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
if_acmpne 15
3: aload 0
dup
astore 4
monitorenter
4: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
astore 2
start local 2 5: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
astore 3
start local 3 6: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
7: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CONNECTED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
8: aload 4
monitorexit
9: goto 12
end local 3 end local 2 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.messages.MqttConnAckMessage top top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
10: aload 4
monitorexit
11: athrow
start local 2 start local 3 12: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.messages.MqttConnAckMessage io.vertx.core.net.impl.NetSocketInternal io.vertx.core.Promise
StackMap stack:
aload 2
aload 0
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;)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/MqttClientImpl.lambda$15(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
13: aload 3
aload 1
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 end local 2 14: goto 35
15: StackMap locals:
StackMap stack:
aload 0
dup
astore 6
monitorenter
16: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
astore 2
start local 2 17: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
astore 3
start local 3 18: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
astore 4
start local 4 19: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.client:Lio/vertx/core/net/NetClient;
astore 5
start local 5 20: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
21: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
22: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
23: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
24: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.client:Lio/vertx/core/net/NetClient;
25: aload 6
monitorexit
26: goto 29
end local 5 end local 4 end local 3 end local 2 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.messages.MqttConnAckMessage top top top top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
27: aload 6
monitorexit
28: athrow
start local 2 start local 3 start local 4 start local 5 29: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.messages.MqttConnAckMessage io.vertx.core.Promise io.vertx.core.Promise io.vertx.core.net.impl.NetSocketInternal io.vertx.core.net.NetClient
StackMap stack:
aload 4
aconst_null
invokeinterface io.vertx.core.net.impl.NetSocketInternal.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
30: new io.vertx.mqtt.MqttConnectionException
dup
aload 1
invokeinterface io.vertx.mqtt.messages.MqttConnAckMessage.code:()Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
invokespecial io.vertx.mqtt.MqttConnectionException.<init>:(Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;)V
astore 6
start local 6 31: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Connection refused by the server - code: %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
invokeinterface io.vertx.mqtt.messages.MqttConnAckMessage.code:()Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
32: aload 2
aload 6
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
33: aload 3
invokeinterface io.vertx.core.Promise.complete:()V
34: aload 5
invokeinterface io.vertx.core.net.NetClient.close:()Lio/vertx/core/Future;
pop
end local 6 end local 5 end local 4 end local 3 end local 2 35: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.mqtt.messages.MqttConnAckMessage
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 36 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 36 1 msg Lio/vertx/mqtt/messages/MqttConnAckMessage;
5 10 2 connection Lio/vertx/core/net/impl/NetSocketInternal;
12 14 2 connection Lio/vertx/core/net/impl/NetSocketInternal;
6 10 3 connectPromise Lio/vertx/core/Promise<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
12 14 3 connectPromise Lio/vertx/core/Promise<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
17 27 2 connectPromise Lio/vertx/core/Promise<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
29 35 2 connectPromise Lio/vertx/core/Promise<Lio/vertx/mqtt/messages/MqttConnAckMessage;>;
18 27 3 disconnectPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
29 35 3 disconnectPromise Lio/vertx/core/Promise<Ljava/lang/Void;>;
19 27 4 connection Lio/vertx/core/net/impl/NetSocketInternal;
29 35 4 connection Lio/vertx/core/net/impl/NetSocketInternal;
20 27 5 client Lio/vertx/core/net/NetClient;
29 35 5 client Lio/vertx/core/net/NetClient;
31 35 6 exception Lio/vertx/mqtt/MqttConnectionException;
Exception table:
from to target type
4 9 10 any
10 11 10 any
16 26 27 any
27 28 27 any
MethodParameters:
Name Flags
msg
private void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.exceptionHandler:()Lio/vertx/core/Handler;
astore 2
start local 2 1: aload 2
ifnull 3
2: aload 2
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 t Ljava/lang/Throwable;
1 4 2 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
MethodParameters:
Name Flags
t
private java.lang.String generateRandomClientId();
descriptor: ()Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
private boolean isValidTopicName(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.isValidStringSizeInUTF8:(Ljava/lang/String;)Z
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
getstatic io.vertx.mqtt.impl.MqttClientImpl.validTopicNamePattern:Ljava/util/regex/Pattern;
aload 1
invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
astore 2
start local 2 3: aload 2
invokevirtual java.util.regex.Matcher.find:()Z
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 topicName Ljava/lang/String;
3 4 2 matcher Ljava/util/regex/Matcher;
MethodParameters:
Name Flags
topicName
private boolean isValidTopicFilter(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.isValidStringSizeInUTF8:(Ljava/lang/String;)Z
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
getstatic io.vertx.mqtt.impl.MqttClientImpl.validTopicFilterPattern:Ljava/util/regex/Pattern;
aload 1
invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
astore 2
start local 2 3: aload 2
invokevirtual java.util.regex.Matcher.find:()Z
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 4 1 topicFilter Ljava/lang/String;
3 4 2 matcher Ljava/util/regex/Matcher;
MethodParameters:
Name Flags
topicFilter
private boolean isValidStringSizeInUTF8(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc "UTF-8"
invokevirtual java.lang.String.getBytes:(Ljava/lang/String;)[B
arraylength
istore 2
start local 2 1: iload 2
iconst_1
if_icmplt 2
iload 2
ldc 65535
if_icmpgt 2
iconst_1
ireturn
StackMap locals: int
StackMap stack:
2: iconst_0
3: ireturn
end local 2 4: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String
StackMap stack: java.io.UnsupportedEncodingException
astore 2
start local 2 5: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "UTF-8 charset is not supported"
aload 2
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 2 6: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 7 1 string Ljava/lang/String;
1 4 2 length I
5 6 2 e Ljava/io/UnsupportedEncodingException;
Exception table:
from to target type
0 3 4 Class java.io.UnsupportedEncodingException
MethodParameters:
Name Flags
string
static int[] $SWITCH_TABLE$io$vertx$mqtt$impl$MqttClientImpl$Status();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$vertx$mqtt$impl$MqttClientImpl$Status:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic io.vertx.mqtt.impl.MqttClientImpl$Status.values:()[Lio/vertx/mqtt/impl/MqttClientImpl$Status;
arraylength
newarray 10
astore 0
2: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Status.ordinal:()I
iconst_1
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSING:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Status.ordinal:()I
iconst_4
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CONNECTED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Status.ordinal:()I
iconst_3
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CONNECTING:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Status.ordinal:()I
iconst_2
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
dup
putstatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$vertx$mqtt$impl$MqttClientImpl$Status:[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
static int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic io.netty.handler.codec.mqtt.MqttQoS.values:()[Lio/netty/handler/codec/mqtt/MqttQoS;
arraylength
newarray 10
astore 0
2: aload 0
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_LEAST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
iconst_2
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
iconst_1
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic io.netty.handler.codec.mqtt.MqttQoS.EXACTLY_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
iconst_3
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic io.netty.handler.codec.mqtt.MqttQoS.FAILURE:Lio/netty/handler/codec/mqtt/MqttQoS;
invokevirtual io.netty.handler.codec.mqtt.MqttQoS.ordinal:()I
iconst_4
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
dup
putstatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttQoS:[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
static int[] $SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic io.netty.handler.codec.mqtt.MqttMessageType.values:()[Lio/netty/handler/codec/mqtt/MqttMessageType;
arraylength
newarray 10
astore 0
2: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.CONNACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
iconst_2
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.CONNECT:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
iconst_1
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.DISCONNECT:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 14
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PINGREQ:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 12
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PINGRESP:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 13
iastore
15: goto 17
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
16: pop
StackMap locals:
StackMap stack:
17: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
iconst_4
iastore
18: goto 20
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
19: pop
StackMap locals:
StackMap stack:
20: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBCOMP:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 7
iastore
21: goto 23
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
22: pop
StackMap locals:
StackMap stack:
23: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBLISH:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
iconst_3
iastore
24: goto 26
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
25: pop
StackMap locals:
StackMap stack:
26: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREC:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
iconst_5
iastore
27: goto 29
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
28: pop
StackMap locals:
StackMap stack:
29: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.PUBREL:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 6
iastore
30: goto 32
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
31: pop
StackMap locals:
StackMap stack:
32: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.SUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 9
iastore
33: goto 35
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
34: pop
StackMap locals:
StackMap stack:
35: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.SUBSCRIBE:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 8
iastore
36: goto 38
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
37: pop
StackMap locals:
StackMap stack:
38: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.UNSUBACK:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 11
iastore
39: goto 41
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
40: pop
StackMap locals:
StackMap stack:
41: aload 0
getstatic io.netty.handler.codec.mqtt.MqttMessageType.UNSUBSCRIBE:Lio/netty/handler/codec/mqtt/MqttMessageType;
invokevirtual io.netty.handler.codec.mqtt.MqttMessageType.ordinal:()I
bipush 10
iastore
42: goto 44
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
43: pop
StackMap locals:
StackMap stack:
44: aload 0
dup
putstatic io.vertx.mqtt.impl.MqttClientImpl.$SWITCH_TABLE$io$netty$handler$codec$mqtt$MqttMessageType:[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
private void lambda$0(java.lang.String, int, io.vertx.core.net.NetClient, java.lang.String, io.vertx.core.impl.future.PromiseInternal, io.vertx.core.impl.future.PromiseInternal, java.lang.Void);
descriptor: (Ljava/lang/String;ILio/vertx/core/net/NetClient;Ljava/lang/String;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=10, locals=8, args_size=8
start local 0 start local 7 0: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Trying to connect with %s:%d"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
1: aload 3
iload 2
aload 1
aload 4
aload 0
aload 1
iload 2
aload 3
aload 5
aload 6
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;Ljava/lang/String;ILio/vertx/core/net/NetClient;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;)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/MqttClientImpl.lambda$1(Ljava/lang/String;ILio/vertx/core/net/NetClient;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.net.NetClient.connect:(ILjava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetClient;
pop
2: return
end local 7 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 3 7 v Ljava/lang/Void;
private boolean lambda$7(java.util.Map$Entry);
descriptor: (Ljava/util/Map$Entry;)Z
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.isValidTopicFilter:(Ljava/lang/String;)Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 3 1 e Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Integer;>;
private static io.netty.handler.codec.mqtt.MqttTopicSubscription lambda$10(java.util.Map$Entry);
descriptor: (Ljava/util/Map$Entry;)Lio/netty/handler/codec/mqtt/MqttTopicSubscription;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new io.netty.handler.codec.mqtt.MqttTopicSubscription
dup
aload 0
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 0
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
invokestatic io.netty.handler.codec.mqtt.MqttQoS.valueOf:(I)Lio/netty/handler/codec/mqtt/MqttQoS;
invokespecial io.netty.handler.codec.mqtt.MqttTopicSubscription.<init>:(Ljava/lang/String;Lio/netty/handler/codec/mqtt/MqttQoS;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 e Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Integer;>;
private void lambda$11(java.lang.Long);
descriptor: (Ljava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.disconnect:()Lio/vertx/core/Future;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 2 1 _id Ljava/lang/Long;
private void lambda$12(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.ping:()Lio/vertx/mqtt/MqttClient;
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 1 1 v Ljava/lang/Void;
private static void lambda$14(io.vertx.mqtt.impl.MqttClientImpl$Ping);
descriptor: (Lio/vertx/mqtt/impl/MqttClientImpl$Ping;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl$Ping.cancel:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 ping Lio/vertx/mqtt/impl/MqttClientImpl$Ping;
private void lambda$15(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handleClosed:()V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 1 1 v Ljava/lang/Void;
private void lambda$1(java.lang.String, int, io.vertx.core.net.NetClient, io.vertx.core.impl.future.PromiseInternal, io.vertx.core.impl.future.PromiseInternal, io.vertx.core.AsyncResult);
descriptor: (Ljava/lang/String;ILio/vertx/core/net/NetClient;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=11, locals=14, args_size=7
start local 0 start local 6 0: aload 6
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 15
1: getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Can't connect to %s:%d"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aload 6
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
2: aload 0
dup
astore 7
monitorenter
3: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
4: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
5: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.ctx:Lio/vertx/core/impl/ContextInternal;
6: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.client:Lio/vertx/core/net/NetClient;
7: aload 7
monitorexit
8: goto 11
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
9: aload 7
monitorexit
10: athrow
11: StackMap locals:
StackMap stack:
aload 3
invokeinterface io.vertx.core.net.NetClient.close:()Lio/vertx/core/Future;
pop
12: aload 4
aload 6
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.future.PromiseInternal.fail:(Ljava/lang/Throwable;)V
13: aload 5
invokeinterface io.vertx.core.impl.future.PromiseInternal.complete:()V
14: goto 77
15: StackMap locals:
StackMap stack:
getstatic io.vertx.mqtt.impl.MqttClientImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Connection with %s:%d established successfully"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.info:(Ljava/lang/Object;)V
16: aload 0
dup
astore 8
monitorenter
17: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSING:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
if_acmpne 18
iconst_1
goto 19
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
18: iconst_0
StackMap locals:
StackMap stack: int
19: dup
istore 7
start local 7 20: ifeq 25
21: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
22: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.client:Lio/vertx/core/net/NetClient;
23: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
24: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
25: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.mqtt.impl.MqttClientImpl
StackMap stack:
aload 8
monitorexit
26: goto 29
end local 7 StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult top io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
27: aload 8
monitorexit
28: athrow
start local 7 29: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int
StackMap stack:
aload 6
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.net.impl.NetSocketInternal
astore 8
start local 8 30: iload 7
ifeq 35
31: aload 8
invokeinterface io.vertx.core.net.impl.NetSocketInternal.close:()Lio/vertx/core/Future;
pop
32: aload 4
ldc "Disconnected"
invokeinterface io.vertx.core.impl.future.PromiseInternal.fail:(Ljava/lang/String;)V
33: aload 5
invokeinterface io.vertx.core.impl.future.PromiseInternal.complete:()V
34: return
35: StackMap locals: io.vertx.core.net.impl.NetSocketInternal
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.isAutoGeneratedClientId:()Z
ifeq 37
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getClientId:()Ljava/lang/String;
ifnull 36
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getClientId:()Ljava/lang/String;
invokevirtual java.lang.String.isEmpty:()Z
ifeq 37
36: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
aload 0
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.generateRandomClientId:()Ljava/lang/String;
invokevirtual io.vertx.mqtt.MqttClientOptions.setClientId:(Ljava/lang/String;)Lio/vertx/mqtt/MqttClientOptions;
pop
37: StackMap locals:
StackMap stack:
aload 0
aload 8
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.initChannel:(Lio/vertx/core/net/impl/NetSocketInternal;)V
38: aload 0
dup
astore 9
monitorenter
39: aload 0
aload 8
putfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
40: aload 9
monitorexit
41: goto 44
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
42: aload 9
monitorexit
43: athrow
44: StackMap locals:
StackMap stack:
aload 8
aload 0
aload 8
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;Lio/vertx/core/net/impl/NetSocketInternal;)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/MqttClientImpl.lambda$2(Lio/vertx/core/net/impl/NetSocketInternal;Ljava/lang/Object;)V (7)
(Ljava/lang/Object;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.messageHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/impl/NetSocketInternal;
pop
45: aload 8
aload 0
aload 3
aload 4
aload 5
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;Lio/vertx/core/net/NetClient;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;)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/MqttClientImpl.lambda$3(Lio/vertx/core/net/NetClient;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
46: aload 8
aload 0
invokedynamic handle(Lio/vertx/mqtt/impl/MqttClientImpl;)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/MqttClientImpl.handleException(Ljava/lang/Throwable;)V (7)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.net.impl.NetSocketInternal.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
47: new io.netty.handler.codec.mqtt.MqttFixedHeader
dup
getstatic io.netty.handler.codec.mqtt.MqttMessageType.CONNECT:Lio/netty/handler/codec/mqtt/MqttMessageType;
48: iconst_0
49: getstatic io.netty.handler.codec.mqtt.MqttQoS.AT_MOST_ONCE:Lio/netty/handler/codec/mqtt/MqttQoS;
50: iconst_0
51: iconst_0
52: invokespecial io.netty.handler.codec.mqtt.MqttFixedHeader.<init>:(Lio/netty/handler/codec/mqtt/MqttMessageType;ZLio/netty/handler/codec/mqtt/MqttQoS;ZI)V
astore 10
start local 10 53: new io.netty.handler.codec.mqtt.MqttConnectVariableHeader
dup
54: ldc "MQTT"
55: iconst_4
56: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.hasUsername:()Z
57: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.hasPassword:()Z
58: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.isWillRetain:()Z
59: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getWillQoS:()I
60: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.isWillFlag:()Z
61: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.isCleanSession:()Z
62: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getKeepAliveInterval:()I
63: invokespecial io.netty.handler.codec.mqtt.MqttConnectVariableHeader.<init>:(Ljava/lang/String;IZZZIZZI)V
astore 11
start local 11 64: new io.netty.handler.codec.mqtt.MqttConnectPayload
dup
65: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getClientId:()Ljava/lang/String;
ifnonnull 66
ldc ""
goto 67
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64
66: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getClientId:()Ljava/lang/String;
67: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64 java.lang.String
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getWillTopic:()Ljava/lang/String;
68: aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getWillMessage:()Ljava/lang/String;
ifnull 69
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getWillMessage:()Ljava/lang/String;
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokevirtual java.lang.String.getBytes:(Ljava/nio/charset/Charset;)[B
goto 70
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64 java.lang.String java.lang.String
69: aconst_null
70: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64 java.lang.String java.lang.String byte[]
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.hasUsername:()Z
ifeq 71
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getUsername:()Ljava/lang/String;
goto 72
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64 java.lang.String java.lang.String byte[]
71: aconst_null
72: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64 java.lang.String java.lang.String byte[] java.lang.String
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.hasPassword:()Z
ifeq 73
aload 0
getfield io.vertx.mqtt.impl.MqttClientImpl.options:Lio/vertx/mqtt/MqttClientOptions;
invokevirtual io.vertx.mqtt.MqttClientOptions.getPassword:()Ljava/lang/String;
invokevirtual java.lang.String.getBytes:()[B
goto 74
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64 java.lang.String java.lang.String byte[] java.lang.String
73: aconst_null
74: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult int io.vertx.core.net.impl.NetSocketInternal top io.netty.handler.codec.mqtt.MqttFixedHeader io.netty.handler.codec.mqtt.MqttConnectVariableHeader
StackMap stack: new 64 new 64 java.lang.String java.lang.String byte[] java.lang.String byte[]
invokespecial io.netty.handler.codec.mqtt.MqttConnectPayload.<init>:(Ljava/lang/String;Ljava/lang/String;[BLjava/lang/String;[B)V
astore 12
start local 12 75: aload 10
aload 11
aload 12
invokestatic io.netty.handler.codec.mqtt.MqttMessageFactory.newMessage:(Lio/netty/handler/codec/mqtt/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)Lio/netty/handler/codec/mqtt/MqttMessage;
astore 13
start local 13 76: aload 0
aload 13
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.write:(Lio/netty/handler/codec/mqtt/MqttMessage;)Lio/vertx/core/Future;
pop
end local 13 end local 12 end local 11 end local 10 end local 8 end local 7 77: StackMap locals: io.vertx.mqtt.impl.MqttClientImpl java.lang.String int io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal io.vertx.core.AsyncResult
StackMap stack:
return
end local 6 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 78 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 78 6 done Lio/vertx/core/AsyncResult<Lio/vertx/core/net/NetSocket;>;
20 27 7 closing Z
29 77 7 closing Z
30 77 8 soi Lio/vertx/core/net/impl/NetSocketInternal;
53 77 10 fixedHeader Lio/netty/handler/codec/mqtt/MqttFixedHeader;
64 77 11 variableHeader Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader;
75 77 12 payload Lio/netty/handler/codec/mqtt/MqttConnectPayload;
76 77 13 connect Lio/netty/handler/codec/mqtt/MqttMessage;
Exception table:
from to target type
3 8 9 any
9 10 9 any
17 26 27 any
27 28 27 any
39 41 42 any
42 43 42 any
private void lambda$2(io.vertx.core.net.impl.NetSocketInternal, java.lang.Object);
descriptor: (Lio/vertx/core/net/impl/NetSocketInternal;Ljava/lang/Object;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.net.impl.NetSocketInternal.channelHandlerContext:()Lio/netty/channel/ChannelHandlerContext;
aload 2
invokevirtual io.vertx.mqtt.impl.MqttClientImpl.handleMessage:(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 1 2 msg Ljava/lang/Object;
private void lambda$3(io.vertx.core.net.NetClient, io.vertx.core.impl.future.PromiseInternal, io.vertx.core.impl.future.PromiseInternal, java.lang.Void);
descriptor: (Lio/vertx/core/net/NetClient;Lio/vertx/core/impl/future/PromiseInternal;Lio/vertx/core/impl/future/PromiseInternal;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=6, args_size=5
start local 0 start local 4 0: aload 1
invokeinterface io.vertx.core.net.NetClient.close:()Lio/vertx/core/Future;
pop
1: aload 0
dup
astore 5
monitorenter
2: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connection:Lio/vertx/core/net/impl/NetSocketInternal;
3: aload 0
getstatic io.vertx.mqtt.impl.MqttClientImpl$Status.CLOSED:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
putfield io.vertx.mqtt.impl.MqttClientImpl.status:Lio/vertx/mqtt/impl/MqttClientImpl$Status;
4: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.connectPromise:Lio/vertx/core/Promise;
5: aload 0
aconst_null
putfield io.vertx.mqtt.impl.MqttClientImpl.disconnectPromise:Lio/vertx/core/Promise;
6: aload 5
monitorexit
7: goto 10
StackMap locals: io.vertx.mqtt.impl.MqttClientImpl io.vertx.core.net.NetClient io.vertx.core.impl.future.PromiseInternal io.vertx.core.impl.future.PromiseInternal java.lang.Void io.vertx.mqtt.impl.MqttClientImpl
StackMap stack: java.lang.Throwable
8: aload 5
monitorexit
9: athrow
10: StackMap locals:
StackMap stack:
aload 2
ldc "Closed"
invokeinterface io.vertx.core.impl.future.PromiseInternal.fail:(Ljava/lang/String;)V
11: aload 3
invokeinterface io.vertx.core.impl.future.PromiseInternal.complete:()V
12: return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/mqtt/impl/MqttClientImpl;
0 13 4 v2 Ljava/lang/Void;
Exception table:
from to target type
2 7 8 any
8 9 8 any
}
SourceFile: "MqttClientImpl.java"
NestMembers:
io.vertx.mqtt.impl.MqttClientImpl$1 io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket io.vertx.mqtt.impl.MqttClientImpl$Ping io.vertx.mqtt.impl.MqttClientImpl$Status
InnerClasses:
io.vertx.mqtt.impl.MqttClientImpl$1
private ExpiringPacket = io.vertx.mqtt.impl.MqttClientImpl$ExpiringPacket of io.vertx.mqtt.impl.MqttClientImpl
private Ping = io.vertx.mqtt.impl.MqttClientImpl$Ping of io.vertx.mqtt.impl.MqttClientImpl
private final Status = io.vertx.mqtt.impl.MqttClientImpl$Status of io.vertx.mqtt.impl.MqttClientImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map