public class io.vertx.amqp.impl.AmqpClientImpl implements io.vertx.amqp.AmqpClient
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.amqp.impl.AmqpClientImpl
super_class: java.lang.Object
{
private final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.proton.ProtonClient proton;
descriptor: Lio/vertx/proton/ProtonClient;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.amqp.AmqpClientOptions options;
descriptor: Lio/vertx/amqp/AmqpClientOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.List<io.vertx.amqp.AmqpConnection> connections;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lio/vertx/amqp/AmqpConnection;>;
private final boolean mustCloseVertxOnClose;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(io.vertx.core.Vertx, io.vertx.amqp.AmqpClientOptions, boolean);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/amqp/AmqpClientOptions;Z)V
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
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.CopyOnWriteArrayList
dup
invokespecial java.util.concurrent.CopyOnWriteArrayList.<init>:()V
putfield io.vertx.amqp.impl.AmqpClientImpl.connections:Ljava/util/List;
2: aload 0
aload 1
putfield io.vertx.amqp.impl.AmqpClientImpl.vertx:Lio/vertx/core/Vertx;
3: aload 2
ifnonnull 6
4: aload 0
new io.vertx.amqp.AmqpClientOptions
dup
invokespecial io.vertx.amqp.AmqpClientOptions.<init>:()V
putfield io.vertx.amqp.impl.AmqpClientImpl.options:Lio/vertx/amqp/AmqpClientOptions;
5: goto 7
6: StackMap locals: io.vertx.amqp.impl.AmqpClientImpl io.vertx.core.Vertx io.vertx.amqp.AmqpClientOptions int
StackMap stack:
aload 0
aload 2
putfield io.vertx.amqp.impl.AmqpClientImpl.options:Lio/vertx/amqp/AmqpClientOptions;
7: StackMap locals:
StackMap stack:
aload 0
aload 1
invokestatic io.vertx.proton.ProtonClient.create:(Lio/vertx/core/Vertx;)Lio/vertx/proton/ProtonClient;
putfield io.vertx.amqp.impl.AmqpClientImpl.proton:Lio/vertx/proton/ProtonClient;
8: aload 0
iload 3
putfield io.vertx.amqp.impl.AmqpClientImpl.mustCloseVertxOnClose:Z
9: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 10 1 vertx Lio/vertx/core/Vertx;
0 10 2 options Lio/vertx/amqp/AmqpClientOptions;
0 10 3 mustCloseVertxOnClose Z
MethodParameters:
Name Flags
vertx
options
mustCloseVertxOnClose
public io.vertx.amqp.AmqpClient connect(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpConnection>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getHost:()Ljava/lang/String;
ldc "Host must be set"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
ldc "Handler must not be null"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: new io.vertx.amqp.impl.AmqpConnectionImpl
aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
aload 0
aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.options:Lio/vertx/amqp/AmqpClientOptions;
aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.proton:Lio/vertx/proton/ProtonClient;
aload 1
invokespecial io.vertx.amqp.impl.AmqpConnectionImpl.<init>:(Lio/vertx/core/Context;Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/amqp/AmqpClientOptions;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler;)V
3: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 4 1 connectionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;>;)Lio/vertx/amqp/AmqpClient;
MethodParameters:
Name Flags
connectionHandler
public io.vertx.core.Future<io.vertx.amqp.AmqpConnection> connect();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.connect:(Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
pop
2: aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
1 3 1 promise Lio/vertx/core/Promise<Lio/vertx/amqp/AmqpConnection;>;
Signature: ()Lio/vertx/core/Future<Lio/vertx/amqp/AmqpConnection;>;
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 1: aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.connections:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 6
StackMap locals: io.vertx.amqp.impl.AmqpClientImpl io.vertx.core.Handler java.util.List top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.amqp.AmqpConnection
astore 3
start local 3 3: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 5
start local 5 4: aload 3
aload 5
invokeinterface io.vertx.amqp.AmqpConnection.close:(Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
pop
5: aload 2
aload 5
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 5 end local 3 6: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
7: aload 2
invokestatic io.vertx.core.CompositeFuture.join:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
aload 0
aload 1
invokedynamic handle(Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/amqp/impl/AmqpClientImpl.lambda$0(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.CompositeFuture.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/CompositeFuture;
pop
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 9 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 9 2 actions Ljava/util/List<Lio/vertx/core/Future;>;
3 6 3 connection Lio/vertx/amqp/AmqpConnection;
4 6 5 future Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 1
start local 1 1: aload 0
aload 1
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.close:(Lio/vertx/core/Handler;)V
2: aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
1 3 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.amqp.AmqpClient createReceiver(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpReceiver>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
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 2
aload 1
invokedynamic handle(Lio/vertx/core/Handler;Ljava/lang/String;)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/amqp/impl/AmqpClientImpl.lambda$2(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.connect:(Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 1 1 address Ljava/lang/String;
0 1 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;)Lio/vertx/amqp/AmqpClient;
MethodParameters:
Name Flags
address
completionHandler
public io.vertx.core.Future<io.vertx.amqp.AmqpReceiver> createReceiver(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.createReceiver:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
pop
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 3 1 address Ljava/lang/String;
1 3 2 promise Lio/vertx/core/Promise<Lio/vertx/amqp/AmqpReceiver;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/amqp/AmqpReceiver;>;
MethodParameters:
Name Flags
address
public io.vertx.amqp.AmqpClient createReceiver(java.lang.String, io.vertx.amqp.AmqpReceiverOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpReceiver>>);
descriptor: (Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
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
aload 3
aload 1
aload 2
invokedynamic handle(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;)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/amqp/impl/AmqpClientImpl.lambda$3(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.connect:(Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
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/amqp/impl/AmqpClientImpl;
0 1 1 address Ljava/lang/String;
0 1 2 receiverOptions Lio/vertx/amqp/AmqpReceiverOptions;
0 1 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;
Signature: (Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;)Lio/vertx/amqp/AmqpClient;
MethodParameters:
Name Flags
address
receiverOptions
completionHandler
public io.vertx.core.Future<io.vertx.amqp.AmqpReceiver> createReceiver(java.lang.String, io.vertx.amqp.AmqpReceiverOptions);
descriptor: (Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 3
start local 3 1: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.createReceiver:(Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
pop
2: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 3 1 address Ljava/lang/String;
0 3 2 receiverOptions Lio/vertx/amqp/AmqpReceiverOptions;
1 3 3 promise Lio/vertx/core/Promise<Lio/vertx/amqp/AmqpReceiver;>;
Signature: (Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;)Lio/vertx/core/Future<Lio/vertx/amqp/AmqpReceiver;>;
MethodParameters:
Name Flags
address
receiverOptions
public io.vertx.amqp.AmqpClient createSender(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpSender>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
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 2
aload 1
invokedynamic handle(Lio/vertx/core/Handler;Ljava/lang/String;)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/amqp/impl/AmqpClientImpl.lambda$4(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.connect:(Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 1 1 address Ljava/lang/String;
0 1 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpSender;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpSender;>;>;)Lio/vertx/amqp/AmqpClient;
MethodParameters:
Name Flags
address
completionHandler
public io.vertx.core.Future<io.vertx.amqp.AmqpSender> createSender(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 2
start local 2 1: aload 0
aload 1
aload 2
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.createSender:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
pop
2: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 3 1 address Ljava/lang/String;
1 3 2 promise Lio/vertx/core/Promise<Lio/vertx/amqp/AmqpSender;>;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/amqp/AmqpSender;>;
MethodParameters:
Name Flags
address
public io.vertx.amqp.AmqpClient createSender(java.lang.String, io.vertx.amqp.AmqpSenderOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpSender>>);
descriptor: (Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
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
aload 3
aload 1
aload 2
invokedynamic handle(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;)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/amqp/impl/AmqpClientImpl.lambda$5(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.connect:(Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
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/amqp/impl/AmqpClientImpl;
0 1 1 address Ljava/lang/String;
0 1 2 options Lio/vertx/amqp/AmqpSenderOptions;
0 1 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpSender;>;>;
Signature: (Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpSender;>;>;)Lio/vertx/amqp/AmqpClient;
MethodParameters:
Name Flags
address
options
completionHandler
public io.vertx.core.Future<io.vertx.amqp.AmqpSender> createSender(java.lang.String, io.vertx.amqp.AmqpSenderOptions);
descriptor: (Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 3
start local 3 1: aload 0
aload 1
aload 2
aload 3
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.createSender:(Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpClient;
pop
2: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 3 1 address Ljava/lang/String;
0 3 2 options Lio/vertx/amqp/AmqpSenderOptions;
1 3 3 promise Lio/vertx/core/Promise<Lio/vertx/amqp/AmqpSender;>;
Signature: (Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;)Lio/vertx/core/Future<Lio/vertx/amqp/AmqpSender;>;
MethodParameters:
Name Flags
address
options
synchronized void register(io.vertx.amqp.impl.AmqpConnectionImpl);
descriptor: (Lio/vertx/amqp/impl/AmqpConnectionImpl;)V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.connections:Ljava/util/List;
aload 1
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 2 1 connection Lio/vertx/amqp/impl/AmqpConnectionImpl;
MethodParameters:
Name Flags
connection
private void lambda$0(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.connections:Ljava/util/List;
invokeinterface java.util.List.clear:()V
1: aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.mustCloseVertxOnClose:Z
ifeq 4
2: aload 0
getfield io.vertx.amqp.impl.AmqpClientImpl.vertx:Lio/vertx/core/Vertx;
aload 2
aload 1
invokedynamic handle(Lio/vertx/core/AsyncResult;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/amqp/impl/AmqpClientImpl.lambda$1(Lio/vertx/core/AsyncResult;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Vertx.close:(Lio/vertx/core/Handler;)V
3: goto 6
StackMap locals:
StackMap stack:
4: aload 1
ifnull 6
5: aload 1
aload 2
invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/amqp/impl/AmqpClientImpl;
0 7 2 done Lio/vertx/core/AsyncResult<Lio/vertx/core/CompositeFuture;>;
private static void lambda$2(io.vertx.core.Handler, java.lang.String, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.amqp.AmqpConnection
aload 1
aload 0
invokeinterface io.vertx.amqp.AmqpConnection.createReceiver:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
pop
4: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 5 2 res Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;
private static void lambda$3(io.vertx.core.Handler, java.lang.String, io.vertx.amqp.AmqpReceiverOptions, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 3
invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.amqp.AmqpConnection
aload 1
aload 2
aload 0
invokeinterface io.vertx.amqp.AmqpConnection.createReceiver:(Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
pop
4: StackMap locals:
StackMap stack:
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 5 3 res Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;
private static void lambda$4(io.vertx.core.Handler, java.lang.String, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.amqp.AmqpConnection
aload 1
aload 0
invokeinterface io.vertx.amqp.AmqpConnection.createSender:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
pop
4: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 5 2 res Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;
private static void lambda$5(io.vertx.core.Handler, java.lang.String, io.vertx.amqp.AmqpSenderOptions, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 3
invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.amqp.AmqpConnection
aload 1
aload 2
aload 0
invokeinterface io.vertx.amqp.AmqpConnection.createSender:(Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
pop
4: StackMap locals:
StackMap stack:
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 5 3 res Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;
private static void lambda$1(io.vertx.core.AsyncResult, io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 1
ifnull 8
2: aload 1
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: goto 8
4: StackMap locals:
StackMap stack:
aload 1
ifnull 8
5: aload 1
aload 0
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 6
aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
goto 7
StackMap locals:
StackMap stack: io.vertx.core.Handler
6: aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
StackMap locals: io.vertx.core.AsyncResult io.vertx.core.Handler io.vertx.core.AsyncResult
StackMap stack: io.vertx.core.Handler java.lang.Throwable
7: invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
8: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 9 2 x Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
}
SourceFile: "AmqpClientImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles