public class io.vertx.amqp.impl.AmqpConnectionImpl implements io.vertx.amqp.AmqpConnection
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.amqp.impl.AmqpConnectionImpl
super_class: java.lang.Object
{
public static final java.lang.String PRODUCT;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "vertx-amqp-client"
public static final org.apache.qpid.proton.amqp.Symbol PRODUCT_KEY;
descriptor: Lorg/apache/qpid/proton/amqp/Symbol;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private final io.vertx.amqp.AmqpClientOptions options;
descriptor: Lio/vertx/amqp/AmqpClientOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicBoolean closed;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicReference<io.vertx.proton.ProtonConnection> connection;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lio/vertx/proton/ProtonConnection;>;
private final io.vertx.core.Context context;
descriptor: Lio/vertx/core/Context;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.List<io.vertx.amqp.AmqpSender> senders;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lio/vertx/amqp/AmqpSender;>;
private final java.util.List<io.vertx.amqp.AmqpReceiver> receivers;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lio/vertx/amqp/AmqpReceiver;>;
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;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc "product"
invokestatic org.apache.qpid.proton.amqp.Symbol.valueOf:(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol;
putstatic io.vertx.amqp.impl.AmqpConnectionImpl.PRODUCT_KEY:Lorg/apache/qpid/proton/amqp/Symbol;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(io.vertx.core.Context, io.vertx.amqp.impl.AmqpClientImpl, io.vertx.amqp.AmqpClientOptions, io.vertx.proton.ProtonClient, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpConnection>>);
descriptor: (Lio/vertx/core/Context;Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/amqp/AmqpClientOptions;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=5, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
3: aload 0
new java.util.concurrent.CopyOnWriteArrayList
dup
invokespecial java.util.concurrent.CopyOnWriteArrayList.<init>:()V
putfield io.vertx.amqp.impl.AmqpConnectionImpl.senders:Ljava/util/List;
4: aload 0
new java.util.concurrent.CopyOnWriteArrayList
dup
invokespecial java.util.concurrent.CopyOnWriteArrayList.<init>:()V
putfield io.vertx.amqp.impl.AmqpConnectionImpl.receivers:Ljava/util/List;
5: aload 0
aload 3
putfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
6: aload 0
aload 1
putfield io.vertx.amqp.impl.AmqpConnectionImpl.context:Lio/vertx/core/Context;
7: aload 0
aload 0
aload 2
aload 4
aload 5
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/proton/ProtonClient;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/AmqpConnectionImpl.lambda$0(Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runOnContext:(Lio/vertx/core/Handler;)V
8: 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 9 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 9 1 context Lio/vertx/core/Context;
0 9 2 client Lio/vertx/amqp/impl/AmqpClientImpl;
0 9 3 options Lio/vertx/amqp/AmqpClientOptions;
0 9 4 proton Lio/vertx/proton/ProtonClient;
0 9 5 connectionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;>;
Signature: (Lio/vertx/core/Context;Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/amqp/AmqpClientOptions;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;>;)V
MethodParameters:
Name Flags
context
client
options
proton
connectionHandler
private void connect(io.vertx.amqp.impl.AmqpClientImpl, io.vertx.proton.ProtonClient, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpConnection>>);
descriptor: (Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
1: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getHost:()Ljava/lang/String;
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getPort:()I
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getUsername:()Ljava/lang/String;
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getPassword:()Ljava/lang/String;
2: aload 0
aload 3
aload 1
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/core/Handler;Lio/vertx/amqp/impl/AmqpClientImpl;)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/AmqpConnectionImpl.lambda$1(Lio/vertx/core/Handler;Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
3: invokeinterface io.vertx.proton.ProtonClient.connect:(Lio/vertx/proton/ProtonClientOptions;Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Lio/vertx/core/Handler;)V
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 5 1 client Lio/vertx/amqp/impl/AmqpClientImpl;
0 5 2 proton Lio/vertx/proton/ProtonClient;
0 5 3 connectionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;>;
Signature: (Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpConnection;>;>;)V
MethodParameters:
Name Flags
client
proton
connectionHandler
private void onDisconnect();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=1
start local 0 0: aconst_null
astore 1
start local 1 1: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
astore 2
start local 2 2: aload 0
dup
astore 3
monitorenter
3: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.exceptionHandler:Lio/vertx/core/Handler;
ifnull 5
4: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.exceptionHandler:Lio/vertx/core/Handler;
astore 1
5: StackMap locals: io.vertx.core.Handler io.vertx.proton.ProtonConnection io.vertx.amqp.impl.AmqpConnectionImpl
StackMap stack:
aload 3
monitorexit
6: goto 9
StackMap locals:
StackMap stack: java.lang.Throwable
7: aload 3
monitorexit
8: athrow
9: StackMap locals:
StackMap stack:
aload 1
ifnull 12
10: aload 0
aload 2
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.getErrorMessage:(Lio/vertx/proton/ProtonConnection;)Ljava/lang/String;
astore 3
start local 3 11: aload 1
new java.lang.Exception
dup
aload 3
invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
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/amqp/impl/AmqpConnectionImpl;
1 13 1 h Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
2 13 2 conn Lio/vertx/proton/ProtonConnection;
11 12 3 message Ljava/lang/String;
Exception table:
from to target type
3 6 7 any
7 8 7 any
private java.lang.String getErrorMessage(io.vertx.proton.ProtonConnection);
descriptor: (Lio/vertx/proton/ProtonConnection;)Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: ldc "Connection disconnected"
astore 2
start local 2 1: aload 1
ifnull 8
2: aload 1
invokeinterface io.vertx.proton.ProtonConnection.getCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
ifnull 5
aload 1
invokeinterface io.vertx.proton.ProtonConnection.getCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
invokevirtual org.apache.qpid.proton.amqp.transport.ErrorCondition.getDescription:()Ljava/lang/String;
ifnull 5
3: new java.lang.StringBuilder
dup
aload 2
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc " - "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface io.vertx.proton.ProtonConnection.getCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
invokevirtual org.apache.qpid.proton.amqp.transport.ErrorCondition.getDescription:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
4: goto 8
5: StackMap locals: java.lang.String
StackMap stack:
aload 1
invokeinterface io.vertx.proton.ProtonConnection.getRemoteCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
ifnull 8
6: aload 1
invokeinterface io.vertx.proton.ProtonConnection.getRemoteCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
invokevirtual org.apache.qpid.proton.amqp.transport.ErrorCondition.getDescription:()Ljava/lang/String;
ifnull 8
7: new java.lang.StringBuilder
dup
aload 2
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc " - "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface io.vertx.proton.ProtonConnection.getRemoteCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
invokevirtual org.apache.qpid.proton.amqp.transport.ErrorCondition.getDescription:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
8: StackMap locals:
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 9 1 conn Lio/vertx/proton/ProtonConnection;
1 9 2 message Ljava/lang/String;
MethodParameters:
Name Flags
conn
void runOnContext(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.context:Lio/vertx/core/Context;
aload 1
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 2 1 action Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
action
void runWithTrampoline(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.context:Lio/vertx/core/Context;
if_acmpne 3
1: aload 1
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runOnContext:(Lio/vertx/core/Handler;)V
4: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 5 1 action Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
action
private boolean isLocalOpen();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
astore 1
start local 1 1: aload 1
ifnull 4
2: aload 1
checkcast io.vertx.proton.impl.ProtonConnectionImpl
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getLocalState:()Lorg/apache/qpid/proton/engine/EndpointState;
getstatic org.apache.qpid.proton.engine.EndpointState.ACTIVE:Lorg/apache/qpid/proton/engine/EndpointState;
if_acmpne 4
3: iconst_1
ireturn
StackMap locals: io.vertx.proton.ProtonConnection
StackMap stack:
4: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
1 5 1 conn Lio/vertx/proton/ProtonConnection;
private boolean isRemoteOpen();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
astore 1
start local 1 1: aload 1
ifnull 4
2: aload 1
checkcast io.vertx.proton.impl.ProtonConnectionImpl
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getRemoteState:()Lorg/apache/qpid/proton/engine/EndpointState;
getstatic org.apache.qpid.proton.engine.EndpointState.ACTIVE:Lorg/apache/qpid/proton/engine/EndpointState;
if_acmpne 4
3: iconst_1
ireturn
StackMap locals: io.vertx.proton.ProtonConnection
StackMap stack:
4: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
1 5 1 conn Lio/vertx/proton/ProtonConnection;
public synchronized io.vertx.amqp.AmqpConnection exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
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.amqp.impl.AmqpConnectionImpl.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/amqp/impl/AmqpConnectionImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/amqp/AmqpConnection;
MethodParameters:
Name Flags
handler
public io.vertx.amqp.AmqpConnection close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.context:Lio/vertx/core/Context;
aload 0
aload 1
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;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/AmqpConnectionImpl.lambda$5(Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 2 1 done Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/amqp/AmqpConnection;
MethodParameters:
Name Flags
done
void unregister(io.vertx.amqp.AmqpSender);
descriptor: (Lio/vertx/amqp/AmqpSender;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.senders:Ljava/util/List;
aload 1
invokeinterface java.util.List.remove:(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/AmqpConnectionImpl;
0 2 1 sender Lio/vertx/amqp/AmqpSender;
MethodParameters:
Name Flags
sender
void unregister(io.vertx.amqp.AmqpReceiver);
descriptor: (Lio/vertx/amqp/AmqpReceiver;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.receivers:Ljava/util/List;
aload 1
invokeinterface java.util.List.remove:(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/AmqpConnectionImpl;
0 2 1 receiver Lio/vertx/amqp/AmqpReceiver;
MethodParameters:
Name Flags
receiver
public io.vertx.amqp.AmqpConnection createReceiver(java.lang.String, io.vertx.core.Handler<io.vertx.amqp.AmqpMessage>, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpReceiver>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aconst_null
aload 2
aload 3
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.createReceiver:(Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
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/AmqpConnectionImpl;
0 1 1 address Ljava/lang/String;
0 1 2 handler Lio/vertx/core/Handler<Lio/vertx/amqp/AmqpMessage;>;
0 1 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/amqp/AmqpMessage;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;)Lio/vertx/amqp/AmqpConnection;
MethodParameters:
Name Flags
address
handler
completionHandler
public io.vertx.amqp.AmqpConnection createDynamicReceiver(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpReceiver>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aconst_null
new io.vertx.amqp.AmqpReceiverOptions
dup
invokespecial io.vertx.amqp.AmqpReceiverOptions.<init>:()V
iconst_1
invokevirtual io.vertx.amqp.AmqpReceiverOptions.setDynamic:(Z)Lio/vertx/amqp/AmqpReceiverOptions;
aconst_null
aload 1
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.createReceiver:(Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 1 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;)Lio/vertx/amqp/AmqpConnection;
MethodParameters:
Name Flags
completionHandler
public io.vertx.amqp.AmqpConnection 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/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.proton.ProtonLinkOptions
dup
invokespecial io.vertx.proton.ProtonLinkOptions.<init>:()V
astore 3
start local 3 1: aload 0
aload 0
aload 1
aload 3
aload 2
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;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/AmqpConnectionImpl.lambda$8(Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
2: aload 0
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/AmqpConnectionImpl;
0 3 1 address Ljava/lang/String;
0 3 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;
1 3 3 opts Lio/vertx/proton/ProtonLinkOptions;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;)Lio/vertx/amqp/AmqpConnection;
MethodParameters:
Name Flags
address
completionHandler
public io.vertx.amqp.AmqpConnection 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/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aconst_null
aload 3
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.createReceiver:(Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
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/AmqpConnectionImpl;
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/AmqpConnection;
MethodParameters:
Name Flags
address
receiverOptions
completionHandler
public io.vertx.amqp.AmqpConnection createReceiver(java.lang.String, io.vertx.amqp.AmqpReceiverOptions, io.vertx.core.Handler<io.vertx.amqp.AmqpMessage>, 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/core/Handler;)Lio/vertx/amqp/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new io.vertx.proton.ProtonLinkOptions
dup
invokespecial io.vertx.proton.ProtonLinkOptions.<init>:()V
astore 5
start local 5 1: aload 2
ifnonnull 2
new io.vertx.amqp.AmqpReceiverOptions
dup
invokespecial io.vertx.amqp.AmqpReceiverOptions.<init>:()V
goto 3
StackMap locals: io.vertx.proton.ProtonLinkOptions
StackMap stack:
2: aload 2
StackMap locals:
StackMap stack: io.vertx.amqp.AmqpReceiverOptions
3: astore 6
start local 6 4: aload 5
5: aload 6
invokevirtual io.vertx.amqp.AmqpReceiverOptions.isDynamic:()Z
invokevirtual io.vertx.proton.ProtonLinkOptions.setDynamic:(Z)Lio/vertx/proton/ProtonLinkOptions;
6: aload 6
invokevirtual io.vertx.amqp.AmqpReceiverOptions.getLinkName:()Ljava/lang/String;
invokevirtual io.vertx.proton.ProtonLinkOptions.setLinkName:(Ljava/lang/String;)Lio/vertx/proton/ProtonLinkOptions;
pop
7: aload 0
aload 0
aload 1
aload 5
aload 2
aload 6
aload 3
aload 4
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/amqp/impl/AmqpConnectionImpl.lambda$9(Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
8: aload 0
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 9 1 address Ljava/lang/String;
0 9 2 receiverOptions Lio/vertx/amqp/AmqpReceiverOptions;
0 9 3 handler Lio/vertx/core/Handler<Lio/vertx/amqp/AmqpMessage;>;
0 9 4 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;
1 9 5 opts Lio/vertx/proton/ProtonLinkOptions;
4 9 6 recOpts Lio/vertx/amqp/AmqpReceiverOptions;
Signature: (Ljava/lang/String;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler<Lio/vertx/amqp/AmqpMessage;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpReceiver;>;>;)Lio/vertx/amqp/AmqpConnection;
MethodParameters:
Name Flags
address
receiverOptions
handler
completionHandler
private void configureTheSource(io.vertx.amqp.AmqpReceiverOptions, io.vertx.proton.ProtonReceiver);
descriptor: (Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/proton/ProtonReceiver;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
1: invokeinterface io.vertx.proton.ProtonReceiver.getSource:()Lorg/apache/qpid/proton/amqp/transport/Source;
2: checkcast org.apache.qpid.proton.amqp.messaging.Source
astore 3
start local 3 3: aload 1
invokevirtual io.vertx.amqp.AmqpReceiverOptions.getCapabilities:()Ljava/util/List;
astore 4
start local 4 4: aload 4
invokeinterface java.util.List.isEmpty:()Z
ifne 6
5: aload 3
aload 4
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
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;
org/apache/qpid/proton/amqp/Symbol.valueOf(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol; (6)
(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/IntFunction;
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:
(I)Ljava/lang/Object;
io/vertx/amqp/impl/AmqpConnectionImpl.lambda$11(I)[Lorg/apache/qpid/proton/amqp/Symbol; (6)
(I)[Lorg/apache/qpid/proton/amqp/Symbol;
invokeinterface java.util.stream.Stream.toArray:(Ljava/util/function/IntFunction;)[Ljava/lang/Object;
checkcast org.apache.qpid.proton.amqp.Symbol[]
invokevirtual org.apache.qpid.proton.amqp.messaging.Source.setCapabilities:([Lorg/apache/qpid/proton/amqp/Symbol;)V
6: StackMap locals: org.apache.qpid.proton.amqp.messaging.Source java.util.List
StackMap stack:
aload 1
invokevirtual io.vertx.amqp.AmqpReceiverOptions.isDurable:()Z
ifeq 9
7: aload 3
getstatic org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy.NEVER:Lorg/apache/qpid/proton/amqp/messaging/TerminusExpiryPolicy;
invokevirtual org.apache.qpid.proton.amqp.messaging.Source.setExpiryPolicy:(Lorg/apache/qpid/proton/amqp/messaging/TerminusExpiryPolicy;)V
8: aload 3
getstatic org.apache.qpid.proton.amqp.messaging.TerminusDurability.UNSETTLED_STATE:Lorg/apache/qpid/proton/amqp/messaging/TerminusDurability;
invokevirtual org.apache.qpid.proton.amqp.messaging.Source.setDurable:(Lorg/apache/qpid/proton/amqp/messaging/TerminusDurability;)V
9: StackMap locals:
StackMap stack:
return
end local 4 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/AmqpConnectionImpl;
0 10 1 receiverOptions Lio/vertx/amqp/AmqpReceiverOptions;
0 10 2 receiver Lio/vertx/proton/ProtonReceiver;
3 10 3 source Lorg/apache/qpid/proton/amqp/messaging/Source;
4 10 4 capabilities Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
receiverOptions
receiver
public io.vertx.amqp.AmqpConnection 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/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "The address must be set"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
new io.vertx.amqp.AmqpSenderOptions
dup
invokespecial io.vertx.amqp.AmqpSenderOptions.<init>:()V
aload 2
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.createSender:(Ljava/lang/String;Lio/vertx/amqp/AmqpSenderOptions;Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 2 1 address Ljava/lang/String;
0 2 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/AmqpConnection;
MethodParameters:
Name Flags
address
completionHandler
public io.vertx.amqp.AmqpConnection 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/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ifnonnull 2
aload 2
invokevirtual io.vertx.amqp.AmqpSenderOptions.isDynamic:()Z
ifne 2
1: new java.lang.IllegalArgumentException
dup
ldc "Address must be set if the link is not dynamic"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 3
ldc "The completion handler must be set"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 0
aload 2
aload 1
aload 3
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/amqp/AmqpSenderOptions;Ljava/lang/String;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/AmqpConnectionImpl.lambda$12(Lio/vertx/amqp/AmqpSenderOptions;Ljava/lang/String;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
4: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 5 1 address Ljava/lang/String;
0 5 2 options Lio/vertx/amqp/AmqpSenderOptions;
0 5 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/AmqpConnection;
MethodParameters:
Name Flags
address
options
completionHandler
public io.vertx.amqp.AmqpConnection createAnonymousSender(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.amqp.AmqpSender>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/amqp/AmqpConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "The completion handler must be set"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 0
aload 1
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;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/AmqpConnectionImpl.lambda$13(Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 3 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpSender;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/amqp/AmqpSender;>;>;)Lio/vertx/amqp/AmqpConnection;
MethodParameters:
Name Flags
completionHandler
io.vertx.proton.ProtonConnection unwrap();
descriptor: ()Lio/vertx/proton/ProtonConnection;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
public io.vertx.amqp.AmqpClientOptions options();
descriptor: ()Lio/vertx/amqp/AmqpClientOptions;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
void register(io.vertx.amqp.impl.AmqpSenderImpl);
descriptor: (Lio/vertx/amqp/impl/AmqpSenderImpl;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.senders: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/AmqpConnectionImpl;
0 2 1 sender Lio/vertx/amqp/impl/AmqpSenderImpl;
MethodParameters:
Name Flags
sender
void register(io.vertx.amqp.impl.AmqpReceiverImpl);
descriptor: (Lio/vertx/amqp/impl/AmqpReceiverImpl;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.receivers: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/AmqpConnectionImpl;
0 2 1 receiver Lio/vertx/amqp/impl/AmqpReceiverImpl;
MethodParameters:
Name Flags
receiver
private void lambda$0(io.vertx.amqp.impl.AmqpClientImpl, io.vertx.proton.ProtonClient, io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 4 0: aload 0
aload 1
1: aload 2
ldc "proton cannot be `null`"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.vertx.proton.ProtonClient
2: aload 3
ldc "connection handler cannot be `null`"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.vertx.core.Handler
3: invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.connect:(Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/proton/ProtonClient;Lio/vertx/core/Handler;)V
4: return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 5 4 x Ljava/lang/Void;
private void lambda$1(io.vertx.core.Handler, io.vertx.amqp.impl.AmqpClientImpl, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 17
1: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 4
2: aload 1
ldc "Unable to connect - already holding a connection"
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: return
4: StackMap locals:
StackMap stack:
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 4
start local 4 5: aload 4
getstatic io.vertx.amqp.impl.AmqpConnectionImpl.PRODUCT_KEY:Lorg/apache/qpid/proton/amqp/Symbol;
ldc "vertx-amqp-client"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getContainerId:()Ljava/lang/String;
ifnull 8
7: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getContainerId:()Ljava/lang/String;
invokeinterface io.vertx.proton.ProtonConnection.setContainer:(Ljava/lang/String;)Lio/vertx/proton/ProtonConnection;
pop
8: StackMap locals: java.util.Map
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getVirtualHost:()Ljava/lang/String;
ifnull 10
9: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.options:Lio/vertx/amqp/AmqpClientOptions;
invokevirtual io.vertx.amqp.AmqpClientOptions.getVirtualHost:()Ljava/lang/String;
invokeinterface io.vertx.proton.ProtonConnection.setHostname:(Ljava/lang/String;)Lio/vertx/proton/ProtonConnection;
pop
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
11: aload 4
invokeinterface io.vertx.proton.ProtonConnection.setProperties:(Ljava/util/Map;)Lio/vertx/proton/ProtonConnection;
12: aload 0
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;)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/AmqpConnectionImpl.lambda$2(Lio/vertx/proton/ProtonConnection;)V (7)
(Lio/vertx/proton/ProtonConnection;)V
invokeinterface io.vertx.proton.ProtonConnection.disconnectHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
13: aload 0
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;)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/AmqpConnectionImpl.lambda$3(Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.proton.ProtonConnection.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
14: aload 0
aload 2
aload 1
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;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/AmqpConnectionImpl.lambda$4(Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.proton.ProtonConnection.openHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
pop
15: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
invokeinterface io.vertx.proton.ProtonConnection.open:()Lio/vertx/proton/ProtonConnection;
pop
end local 4 16: goto 18
17: StackMap locals:
StackMap stack:
aload 1
aload 3
invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
18: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 19 3 ar Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;
5 16 4 map Ljava/util/Map<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;
private void lambda$5(io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=6, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
astore 3
start local 3 1: aload 3
ifnull 2
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifne 2
aload 0
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.isLocalOpen:()Z
ifne 5
aload 0
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.isRemoteOpen:()Z
ifne 5
2: StackMap locals: io.vertx.proton.ProtonConnection
StackMap stack:
aload 1
ifnull 4
3: aload 1
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: StackMap locals:
StackMap stack:
return
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
6: invokestatic io.vertx.core.Future.future:()Lio/vertx/core/Future;
astore 4
start local 4 7: aload 1
ifnull 9
8: aload 4
aload 1
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
9: StackMap locals: io.vertx.core.Future
StackMap stack:
aload 3
invokeinterface io.vertx.proton.ProtonConnection.isDisconnected:()Z
ifeq 12
10: aload 4
invokeinterface io.vertx.core.Future.complete:()V
11: goto 19
12: StackMap locals:
StackMap stack:
aload 3
13: aload 0
aload 4
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/core/Future;)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/AmqpConnectionImpl.lambda$6(Lio/vertx/core/Future;Lio/vertx/proton/ProtonConnection;)V (7)
(Lio/vertx/proton/ProtonConnection;)V
invokeinterface io.vertx.proton.ProtonConnection.disconnectHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
14: aload 0
aload 4
invokedynamic handle(Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/core/Future;)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/AmqpConnectionImpl.lambda$7(Lio/vertx/core/Future;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.proton.ProtonConnection.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
15: invokeinterface io.vertx.proton.ProtonConnection.close:()Lio/vertx/proton/ProtonConnection;
pop
16: goto 19
StackMap locals:
StackMap stack: java.lang.Exception
17: astore 5
start local 5 18: aload 4
aload 5
invokeinterface io.vertx.core.Future.fail:(Ljava/lang/Throwable;)V
end local 5 end local 4 end local 3 19: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 20 2 ignored Ljava/lang/Void;
1 19 3 actualConnection Lio/vertx/proton/ProtonConnection;
7 19 4 future Lio/vertx/core/Future<Ljava/lang/Void;>;
18 19 5 e Ljava/lang/Exception;
Exception table:
from to target type
12 16 17 Class java.lang.Exception
private void lambda$8(java.lang.String, io.vertx.proton.ProtonLinkOptions, io.vertx.core.Handler, java.lang.Void);
descriptor: (Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=8, locals=6, args_size=5
start local 0 start local 4 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
aload 1
aload 2
invokeinterface io.vertx.proton.ProtonConnection.createReceiver:(Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;)Lio/vertx/proton/ProtonReceiver;
astore 5
start local 5 1: new io.vertx.amqp.impl.AmqpReceiverImpl
2: aload 1
ldc "The address must not be `null`"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.lang.String
3: aload 0
new io.vertx.amqp.AmqpReceiverOptions
dup
invokespecial io.vertx.amqp.AmqpReceiverOptions.<init>:()V
aload 5
aconst_null
4: aload 3
ldc "The completion handler must not be `null`"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast io.vertx.core.Handler
5: invokespecial io.vertx.amqp.impl.AmqpReceiverImpl.<init>:(Ljava/lang/String;Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/proton/ProtonReceiver;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
end local 5 6: return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 7 4 x Ljava/lang/Void;
1 6 5 receiver Lio/vertx/proton/ProtonReceiver;
private void lambda$9(java.lang.String, io.vertx.proton.ProtonLinkOptions, io.vertx.amqp.AmqpReceiverOptions, io.vertx.amqp.AmqpReceiverOptions, io.vertx.core.Handler, io.vertx.core.Handler, java.lang.Void);
descriptor: (Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/core/Handler;Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=7, locals=9, args_size=8
start local 0 start local 7 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
aload 1
aload 2
invokeinterface io.vertx.proton.ProtonConnection.createReceiver:(Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;)Lio/vertx/proton/ProtonReceiver;
astore 8
start local 8 1: aload 3
ifnull 5
2: aload 3
invokevirtual io.vertx.amqp.AmqpReceiverOptions.getQos:()Ljava/lang/String;
ifnull 4
3: aload 8
aload 3
invokevirtual io.vertx.amqp.AmqpReceiverOptions.getQos:()Ljava/lang/String;
invokevirtual java.lang.String.toUpperCase:()Ljava/lang/String;
invokestatic io.vertx.proton.ProtonQoS.valueOf:(Ljava/lang/String;)Lio/vertx/proton/ProtonQoS;
invokeinterface io.vertx.proton.ProtonReceiver.setQoS:(Lio/vertx/proton/ProtonQoS;)Lio/vertx/proton/ProtonLink;
pop
4: StackMap locals: io.vertx.proton.ProtonReceiver
StackMap stack:
aload 0
aload 4
aload 8
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.configureTheSource:(Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/proton/ProtonReceiver;)V
5: StackMap locals:
StackMap stack:
new io.vertx.amqp.impl.AmqpReceiverImpl
aload 1
aload 0
aload 4
aload 8
aload 5
aload 6
invokespecial io.vertx.amqp.impl.AmqpReceiverImpl.<init>:(Ljava/lang/String;Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/amqp/AmqpReceiverOptions;Lio/vertx/proton/ProtonReceiver;Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
end local 8 6: return
end local 7 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 7 7 v Ljava/lang/Void;
1 6 8 receiver Lio/vertx/proton/ProtonReceiver;
private static org.apache.qpid.proton.amqp.Symbol[] lambda$11(int);
descriptor: (I)[Lorg/apache/qpid/proton/amqp/Symbol;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: iload 0
anewarray org.apache.qpid.proton.amqp.Symbol
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$12(io.vertx.amqp.AmqpSenderOptions, java.lang.String, io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/amqp/AmqpSenderOptions;Ljava/lang/String;Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=7, args_size=5
start local 0 start local 4 0: aload 1
ifnull 7
1: new io.vertx.proton.ProtonLinkOptions
dup
invokespecial io.vertx.proton.ProtonLinkOptions.<init>:()V
astore 6
start local 6 2: aload 6
aload 1
invokevirtual io.vertx.amqp.AmqpSenderOptions.getLinkName:()Ljava/lang/String;
invokevirtual io.vertx.proton.ProtonLinkOptions.setLinkName:(Ljava/lang/String;)Lio/vertx/proton/ProtonLinkOptions;
pop
3: aload 6
aload 1
invokevirtual io.vertx.amqp.AmqpSenderOptions.isDynamic:()Z
invokevirtual io.vertx.proton.ProtonLinkOptions.setDynamic:(Z)Lio/vertx/proton/ProtonLinkOptions;
pop
4: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
aload 2
aload 6
invokeinterface io.vertx.proton.ProtonConnection.createSender:(Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;)Lio/vertx/proton/ProtonSender;
astore 5
start local 5 5: aload 5
aload 1
invokevirtual io.vertx.amqp.AmqpSenderOptions.isAutoDrained:()Z
invokeinterface io.vertx.proton.ProtonSender.setAutoDrained:(Z)Lio/vertx/proton/ProtonSender;
pop
end local 6 6: goto 8
end local 5 7: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
aload 2
invokeinterface io.vertx.proton.ProtonConnection.createSender:(Ljava/lang/String;)Lio/vertx/proton/ProtonSender;
astore 5
start local 5 8: StackMap locals: io.vertx.proton.ProtonSender
StackMap stack:
aload 5
aload 0
aload 3
invokestatic io.vertx.amqp.impl.AmqpSenderImpl.create:(Lio/vertx/proton/ProtonSender;Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/core/Handler;)V
end local 5 9: return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 10 4 x Ljava/lang/Void;
5 7 5 sender Lio/vertx/proton/ProtonSender;
8 9 5 sender Lio/vertx/proton/ProtonSender;
2 6 6 opts Lio/vertx/proton/ProtonLinkOptions;
private void lambda$13(io.vertx.core.Handler, java.lang.Void);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.connection:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.vertx.proton.ProtonConnection
aconst_null
invokeinterface io.vertx.proton.ProtonConnection.createSender:(Ljava/lang/String;)Lio/vertx/proton/ProtonSender;
astore 3
start local 3 1: aload 3
aload 0
aload 1
invokestatic io.vertx.amqp.impl.AmqpSenderImpl.create:(Lio/vertx/proton/ProtonSender;Lio/vertx/amqp/impl/AmqpConnectionImpl;Lio/vertx/core/Handler;)V
end local 3 2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 3 2 x Ljava/lang/Void;
1 2 3 sender Lio/vertx/proton/ProtonSender;
private void lambda$2(io.vertx.proton.ProtonConnection);
descriptor: (Lio/vertx/proton/ProtonConnection;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.onDisconnect:()V
1: goto 5
StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 2
3: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
4: aload 2
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 7 1 ignored Lio/vertx/proton/ProtonConnection;
Exception table:
from to target type
0 2 2 any
private void lambda$3(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.onDisconnect:()V
1: goto 5
StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 2
3: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
4: aload 2
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 7 1 x Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;
Exception table:
from to target type
0 2 2 any
private void lambda$4(io.vertx.amqp.impl.AmqpClientImpl, io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/amqp/impl/AmqpClientImpl;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=4
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 5
1: aload 1
aload 0
invokevirtual io.vertx.amqp.impl.AmqpClientImpl.register:(Lio/vertx/amqp/impl/AmqpConnectionImpl;)V
2: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
3: aload 2
aload 0
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: goto 7
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
6: aload 2
aload 3
invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 8 3 conn Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;
private void lambda$6(io.vertx.core.Future, io.vertx.proton.ProtonConnection);
descriptor: (Lio/vertx/core/Future;Lio/vertx/proton/ProtonConnection;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 1
aload 0
aload 2
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.getErrorMessage:(Lio/vertx/proton/ProtonConnection;)Ljava/lang/String;
invokeinterface io.vertx.core.Future.tryFail:(Ljava/lang/String;)Z
pop
1: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 3 2 con Lio/vertx/proton/ProtonConnection;
private void lambda$7(io.vertx.core.Future, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Future;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.amqp.impl.AmqpConnectionImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
1: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
2: aload 1
invokeinterface io.vertx.core.Future.tryComplete:()Z
pop
3: goto 5
4: StackMap locals:
StackMap stack:
aload 1
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.Future.tryFail:(Ljava/lang/Throwable;)Z
pop
5: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/amqp/impl/AmqpConnectionImpl;
0 6 2 res Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;
}
SourceFile: "AmqpConnectionImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles