public class io.vertx.proton.impl.ProtonConnectionImpl implements io.vertx.proton.ProtonConnection
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.proton.impl.ProtonConnectionImpl
super_class: java.lang.Object
{
private static final io.vertx.core.logging.Logger LOG;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final org.apache.qpid.proton.amqp.Symbol ANONYMOUS_RELAY;
descriptor: Lorg/apache/qpid/proton/amqp/Symbol;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private final org.apache.qpid.proton.engine.Connection connection;
descriptor: Lorg/apache/qpid/proton/engine/Connection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.ContextInternal connCtx;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.proton.impl.ProtonTransport transport;
descriptor: Lio/vertx/proton/impl/ProtonTransport;
flags: (0x0002) ACC_PRIVATE
private java.util.List<io.vertx.core.Handler<java.lang.Void>> endHandlers;
descriptor: Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/List<Lio/vertx/core/Handler<Ljava/lang/Void;>;>;
private io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.proton.ProtonConnection>> openHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;>;
private io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.proton.ProtonConnection>> closeHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;>;
private io.vertx.core.Handler<io.vertx.proton.ProtonConnection> disconnectHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/proton/ProtonConnection;>;
private io.vertx.core.Handler<io.vertx.proton.ProtonSession> sessionOpenHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSession;>;
private io.vertx.core.Handler<io.vertx.proton.ProtonSender> senderOpenHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSender;>;
private io.vertx.core.Handler<io.vertx.proton.ProtonReceiver> receiverOpenHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/proton/ProtonReceiver;>;
private boolean anonymousRelaySupported;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private io.vertx.proton.ProtonSession defaultSession;
descriptor: Lio/vertx/proton/ProtonSession;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/proton/impl/ProtonConnectionImpl;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.proton.impl.ProtonConnectionImpl.LOG:Lio/vertx/core/logging/Logger;
1: ldc "ANONYMOUS-RELAY"
invokestatic org.apache.qpid.proton.amqp.Symbol.valueOf:(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol;
putstatic io.vertx.proton.impl.ProtonConnectionImpl.ANONYMOUS_RELAY:Lorg/apache/qpid/proton/amqp/Symbol;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(io.vertx.core.Vertx, java.lang.String, io.vertx.core.impl.ContextInternal);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/core/impl/ContextInternal;)V
flags: (0x0000)
Code:
stack=4, locals=5, 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
invokestatic org.apache.qpid.proton.Proton.connection:()Lorg/apache/qpid/proton/engine/Connection;
putfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
2: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield io.vertx.proton.impl.ProtonConnectionImpl.endHandlers:Ljava/util/List;
3: aload 0
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/proton/impl/ProtonConnectionImpl.lambda$0(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.openHandler:Lio/vertx/core/Handler;
4: aload 0
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/proton/impl/ProtonConnectionImpl.lambda$1(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.closeHandler:Lio/vertx/core/Handler;
5: aload 0
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/proton/impl/ProtonConnectionImpl.lambda$2(Lio/vertx/proton/ProtonConnection;)V (6)
(Lio/vertx/proton/ProtonConnection;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.disconnectHandler:Lio/vertx/core/Handler;
6: aload 0
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/proton/impl/ProtonConnectionImpl.lambda$3(Lio/vertx/proton/ProtonSession;)V (6)
(Lio/vertx/proton/ProtonSession;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.sessionOpenHandler:Lio/vertx/core/Handler;
7: aload 0
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/proton/impl/ProtonConnectionImpl.lambda$4(Lio/vertx/proton/ProtonSender;)V (6)
(Lio/vertx/proton/ProtonSender;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.senderOpenHandler:Lio/vertx/core/Handler;
8: aload 0
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/proton/impl/ProtonConnectionImpl.lambda$5(Lio/vertx/proton/ProtonReceiver;)V (6)
(Lio/vertx/proton/ProtonReceiver;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.receiverOpenHandler:Lio/vertx/core/Handler;
9: aload 0
aload 1
putfield io.vertx.proton.impl.ProtonConnectionImpl.vertx:Lio/vertx/core/Vertx;
10: aload 0
aload 3
putfield io.vertx.proton.impl.ProtonConnectionImpl.connCtx:Lio/vertx/core/impl/ContextInternal;
11: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 0
invokeinterface org.apache.qpid.proton.engine.Connection.setContext:(Ljava/lang/Object;)V
12: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
new java.lang.StringBuilder
dup
ldc "vert.x-"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.apache.qpid.proton.engine.Connection.setContainer:(Ljava/lang/String;)V
13: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 2
invokeinterface org.apache.qpid.proton.engine.Connection.setHostname:(Ljava/lang/String;)V
14: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.createInitialPropertiesMap:()Ljava/util/LinkedHashMap;
astore 4
start local 4 15: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 4
invokeinterface org.apache.qpid.proton.engine.Connection.setProperties:(Ljava/util/Map;)V
16: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 17 1 vertx Lio/vertx/core/Vertx;
0 17 2 hostname Ljava/lang/String;
0 17 3 connCtx Lio/vertx/core/impl/ContextInternal;
15 17 4 props Ljava/util/Map<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;
MethodParameters:
Name Flags
vertx
hostname
connCtx
private java.util.LinkedHashMap<org.apache.qpid.proton.amqp.Symbol, java.lang.Object> createInitialPropertiesMap();
descriptor: ()Ljava/util/LinkedHashMap;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=1
start local 0 0: new java.util.LinkedHashMap
dup
invokespecial java.util.LinkedHashMap.<init>:()V
astore 1
start local 1 1: aload 1
getstatic io.vertx.proton.impl.ProtonMetaDataSupportImpl.PRODUCT_KEY:Lorg/apache/qpid/proton/amqp/Symbol;
ldc "vertx-proton"
invokevirtual java.util.LinkedHashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 1
getstatic io.vertx.proton.impl.ProtonMetaDataSupportImpl.VERSION_KEY:Lorg/apache/qpid/proton/amqp/Symbol;
getstatic io.vertx.proton.impl.ProtonMetaDataSupportImpl.VERSION:Ljava/lang/String;
invokevirtual java.util.LinkedHashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
1 4 1 props Ljava/util/LinkedHashMap<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;
Signature: ()Ljava/util/LinkedHashMap<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;
public io.vertx.proton.impl.ProtonConnectionImpl setProperties(java.util.Map<org.apache.qpid.proton.amqp.Symbol, java.lang.Object>);
descriptor: (Ljava/util/Map;)Lio/vertx/proton/impl/ProtonConnectionImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aconst_null
astore 2
start local 2 1: aload 1
ifnull 4
2: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.createInitialPropertiesMap:()Ljava/util/LinkedHashMap;
astore 2
3: aload 2
aload 1
invokevirtual java.util.LinkedHashMap.putAll:(Ljava/util/Map;)V
4: StackMap locals: java.util.LinkedHashMap
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 2
invokeinterface org.apache.qpid.proton.engine.Connection.setProperties:(Ljava/util/Map;)V
5: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 6 1 properties Ljava/util/Map<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;
1 6 2 newProps Ljava/util/LinkedHashMap<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;
Signature: (Ljava/util/Map<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;)Lio/vertx/proton/impl/ProtonConnectionImpl;
MethodParameters:
Name Flags
properties final
public io.vertx.proton.impl.ProtonConnectionImpl setOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[]);
descriptor: ([Lorg/apache/qpid/proton/amqp/Symbol;)Lio/vertx/proton/impl/ProtonConnectionImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 1
invokeinterface org.apache.qpid.proton.engine.Connection.setOfferedCapabilities:([Lorg/apache/qpid/proton/amqp/Symbol;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 2 1 capabilities [Lorg/apache/qpid/proton/amqp/Symbol;
MethodParameters:
Name Flags
capabilities
public io.vertx.proton.impl.ProtonConnectionImpl setHostname(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/proton/impl/ProtonConnectionImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 1
invokeinterface org.apache.qpid.proton.engine.Connection.setHostname:(Ljava/lang/String;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 2 1 hostname Ljava/lang/String;
MethodParameters:
Name Flags
hostname
public io.vertx.proton.impl.ProtonConnectionImpl setDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[]);
descriptor: ([Lorg/apache/qpid/proton/amqp/Symbol;)Lio/vertx/proton/impl/ProtonConnectionImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 1
invokeinterface org.apache.qpid.proton.engine.Connection.setDesiredCapabilities:([Lorg/apache/qpid/proton/amqp/Symbol;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 2 1 capabilities [Lorg/apache/qpid/proton/amqp/Symbol;
MethodParameters:
Name Flags
capabilities
public io.vertx.proton.impl.ProtonConnectionImpl setContainer(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/proton/impl/ProtonConnectionImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 1
invokeinterface org.apache.qpid.proton.engine.Connection.setContainer:(Ljava/lang/String;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 2 1 container Ljava/lang/String;
MethodParameters:
Name Flags
container
public io.vertx.proton.impl.ProtonConnectionImpl setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition);
descriptor: (Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/impl/ProtonConnectionImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 1
invokeinterface org.apache.qpid.proton.engine.Connection.setCondition:(Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)V
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 2 1 condition Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
MethodParameters:
Name Flags
condition
public org.apache.qpid.proton.amqp.transport.ErrorCondition getCondition();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public java.lang.String getContainer();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getContainer:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public java.lang.String getHostname();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getHostname:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public org.apache.qpid.proton.engine.EndpointState getLocalState();
descriptor: ()Lorg/apache/qpid/proton/engine/EndpointState;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getLocalState:()Lorg/apache/qpid/proton/engine/EndpointState;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public org.apache.qpid.proton.amqp.transport.ErrorCondition getRemoteCondition();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getRemoteCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public java.lang.String getRemoteContainer();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getRemoteContainer:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public org.apache.qpid.proton.amqp.Symbol[] getRemoteDesiredCapabilities();
descriptor: ()[Lorg/apache/qpid/proton/amqp/Symbol;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getRemoteDesiredCapabilities:()[Lorg/apache/qpid/proton/amqp/Symbol;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public java.lang.String getRemoteHostname();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getRemoteHostname:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public org.apache.qpid.proton.amqp.Symbol[] getRemoteOfferedCapabilities();
descriptor: ()[Lorg/apache/qpid/proton/amqp/Symbol;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getRemoteOfferedCapabilities:()[Lorg/apache/qpid/proton/amqp/Symbol;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public java.util.Map<org.apache.qpid.proton.amqp.Symbol, java.lang.Object> getRemoteProperties();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getRemoteProperties:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
Signature: ()Ljava/util/Map<Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/Object;>;
public org.apache.qpid.proton.engine.EndpointState getRemoteState();
descriptor: ()Lorg/apache/qpid/proton/engine/EndpointState;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getRemoteState:()Lorg/apache/qpid/proton/engine/EndpointState;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public boolean isAnonymousRelaySupported();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.anonymousRelaySupported:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public org.apache.qpid.proton.engine.Record attachments();
descriptor: ()Lorg/apache/qpid/proton/engine/Record;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.attachments:()Lorg/apache/qpid/proton/engine/Record;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public io.vertx.proton.ProtonConnection open();
descriptor: ()Lio/vertx/proton/ProtonConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.open:()V
1: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.flush:()V
2: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public io.vertx.proton.ProtonConnection close();
descriptor: ()Lio/vertx/proton/ProtonConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.close:()V
1: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.flush:()V
2: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public io.vertx.proton.impl.ProtonSessionImpl createSession();
descriptor: ()Lio/vertx/proton/impl/ProtonSessionImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.vertx.proton.impl.ProtonSessionImpl
dup
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.session:()Lorg/apache/qpid/proton/engine/Session;
invokespecial io.vertx.proton.impl.ProtonSessionImpl.<init>:(Lorg/apache/qpid/proton/engine/Session;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
private io.vertx.proton.ProtonSession getDefaultSession();
descriptor: ()Lio/vertx/proton/ProtonSession;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.defaultSession:Lio/vertx/proton/ProtonSession;
ifnonnull 4
1: aload 0
aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.createSession:()Lio/vertx/proton/impl/ProtonSessionImpl;
putfield io.vertx.proton.impl.ProtonConnectionImpl.defaultSession:Lio/vertx/proton/ProtonSession;
2: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.defaultSession:Lio/vertx/proton/ProtonSession;
aload 0
invokedynamic handle(Lio/vertx/proton/impl/ProtonConnectionImpl;)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/proton/impl/ProtonConnectionImpl.lambda$6(Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.proton.ProtonSession.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonSession;
pop
3: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.defaultSession:Lio/vertx/proton/ProtonSession;
invokeinterface io.vertx.proton.ProtonSession.open:()Lio/vertx/proton/ProtonSession;
pop
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.defaultSession:Lio/vertx/proton/ProtonSession;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public io.vertx.proton.ProtonSender createSender(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/proton/ProtonSender;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getDefaultSession:()Lio/vertx/proton/ProtonSession;
aload 1
invokeinterface io.vertx.proton.ProtonSession.createSender:(Ljava/lang/String;)Lio/vertx/proton/ProtonSender;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 1 1 address Ljava/lang/String;
MethodParameters:
Name Flags
address
public io.vertx.proton.ProtonSender createSender(java.lang.String, io.vertx.proton.ProtonLinkOptions);
descriptor: (Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;)Lio/vertx/proton/ProtonSender;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getDefaultSession:()Lio/vertx/proton/ProtonSession;
aload 1
aload 2
invokeinterface io.vertx.proton.ProtonSession.createSender:(Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;)Lio/vertx/proton/ProtonSender;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 1 1 address Ljava/lang/String;
0 1 2 senderOptions Lio/vertx/proton/ProtonLinkOptions;
MethodParameters:
Name Flags
address
senderOptions
public io.vertx.proton.ProtonReceiver createReceiver(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/proton/ProtonReceiver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getDefaultSession:()Lio/vertx/proton/ProtonSession;
aload 1
invokeinterface io.vertx.proton.ProtonSession.createReceiver:(Ljava/lang/String;)Lio/vertx/proton/ProtonReceiver;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 1 1 address Ljava/lang/String;
MethodParameters:
Name Flags
address
public io.vertx.proton.ProtonReceiver createReceiver(java.lang.String, io.vertx.proton.ProtonLinkOptions);
descriptor: (Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;)Lio/vertx/proton/ProtonReceiver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getDefaultSession:()Lio/vertx/proton/ProtonSession;
aload 1
aload 2
invokeinterface io.vertx.proton.ProtonSession.createReceiver:(Ljava/lang/String;Lio/vertx/proton/ProtonLinkOptions;)Lio/vertx/proton/ProtonReceiver;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 1 1 address Ljava/lang/String;
0 1 2 receiverOptions Lio/vertx/proton/ProtonLinkOptions;
MethodParameters:
Name Flags
address
receiverOptions
public void flush();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
ifnull 2
1: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
invokevirtual io.vertx.proton.impl.ProtonTransport.flush:()V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public void disconnect();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
ifnull 2
1: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
invokevirtual io.vertx.proton.impl.ProtonTransport.disconnect:()V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public boolean isDisconnected();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
ifnonnull 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/proton/impl/ProtonConnectionImpl;
public io.vertx.proton.ProtonConnection openHandler(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.proton.ProtonConnection>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
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.proton.impl.ProtonConnectionImpl.openHandler: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/proton/impl/ProtonConnectionImpl;
0 2 1 openHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;>;)Lio/vertx/proton/ProtonConnection;
MethodParameters:
Name Flags
openHandler
public io.vertx.proton.ProtonConnection closeHandler(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.proton.ProtonConnection>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
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.proton.impl.ProtonConnectionImpl.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/proton/impl/ProtonConnectionImpl;
0 2 1 closeHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;>;)Lio/vertx/proton/ProtonConnection;
MethodParameters:
Name Flags
closeHandler
public io.vertx.proton.ProtonConnection disconnectHandler(io.vertx.core.Handler<io.vertx.proton.ProtonConnection>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
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.proton.impl.ProtonConnectionImpl.disconnectHandler: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/proton/impl/ProtonConnectionImpl;
0 2 1 disconnectHandler Lio/vertx/core/Handler<Lio/vertx/proton/ProtonConnection;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/proton/ProtonConnection;>;)Lio/vertx/proton/ProtonConnection;
MethodParameters:
Name Flags
disconnectHandler
public io.vertx.proton.ProtonConnection sessionOpenHandler(io.vertx.core.Handler<io.vertx.proton.ProtonSession>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
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.proton.impl.ProtonConnectionImpl.sessionOpenHandler: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/proton/impl/ProtonConnectionImpl;
0 2 1 remoteSessionOpenHandler Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSession;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSession;>;)Lio/vertx/proton/ProtonConnection;
MethodParameters:
Name Flags
remoteSessionOpenHandler
public io.vertx.proton.ProtonConnection senderOpenHandler(io.vertx.core.Handler<io.vertx.proton.ProtonSender>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
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.proton.impl.ProtonConnectionImpl.senderOpenHandler: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/proton/impl/ProtonConnectionImpl;
0 2 1 remoteSenderOpenHandler Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSender;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSender;>;)Lio/vertx/proton/ProtonConnection;
MethodParameters:
Name Flags
remoteSenderOpenHandler
public io.vertx.proton.ProtonConnection receiverOpenHandler(io.vertx.core.Handler<io.vertx.proton.ProtonReceiver>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonConnection;
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.proton.impl.ProtonConnectionImpl.receiverOpenHandler: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/proton/impl/ProtonConnectionImpl;
0 2 1 remoteReceiverOpenHandler Lio/vertx/core/Handler<Lio/vertx/proton/ProtonReceiver;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/proton/ProtonReceiver;>;)Lio/vertx/proton/ProtonConnection;
MethodParameters:
Name Flags
remoteReceiverOpenHandler
private void processCapabilities();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getRemoteOfferedCapabilities:()[Lorg/apache/qpid/proton/amqp/Symbol;
astore 1
start local 1 1: aload 1
ifnull 5
2: aload 1
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
astore 2
start local 2 3: aload 2
getstatic io.vertx.proton.impl.ProtonConnectionImpl.ANONYMOUS_RELAY:Lorg/apache/qpid/proton/amqp/Symbol;
invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
ifeq 5
4: aload 0
iconst_1
putfield io.vertx.proton.impl.ProtonConnectionImpl.anonymousRelaySupported:Z
end local 2 5: StackMap locals: org.apache.qpid.proton.amqp.Symbol[]
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
1 6 1 capabilities [Lorg/apache/qpid/proton/amqp/Symbol;
3 5 2 list Ljava/util/List<Lorg/apache/qpid/proton/amqp/Symbol;>;
void fireRemoteOpen();
descriptor: ()V
flags: (0x0000)
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.processCapabilities:()V
1: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.openHandler:Lio/vertx/core/Handler;
ifnull 3
2: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.openHandler:Lio/vertx/core/Handler;
aload 0
aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getRemoteCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
invokestatic io.vertx.proton.ProtonHelper.future:(Ljava/lang/Object;Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
void fireRemoteClose();
descriptor: ()V
flags: (0x0000)
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.closeHandler:Lio/vertx/core/Handler;
ifnull 2
1: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.closeHandler:Lio/vertx/core/Handler;
aload 0
aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.getRemoteCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
invokestatic io.vertx.proton.ProtonHelper.future:(Ljava/lang/Object;Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/core/AsyncResult;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public void fireDisconnect();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
1: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.disconnectHandler:Lio/vertx/core/Handler;
ifnull 3
2: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.disconnectHandler:Lio/vertx/core/Handler;
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.endHandlers:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 1
start local 1 4: goto 8
5: StackMap locals: java.util.Iterator
StackMap stack:
aload 1
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.core.Handler
astore 2
start local 2 6: aload 1
invokeinterface java.util.Iterator.remove:()V
7: aload 2
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 2 8: StackMap locals:
StackMap stack:
aload 1
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
9: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
4 10 1 iter Ljava/util/Iterator<Lio/vertx/core/Handler<Ljava/lang/Void;>;>;
6 8 2 h Lio/vertx/core/Handler<Ljava/lang/Void;>;
void bindClient(io.vertx.core.net.NetClient, io.vertx.core.net.NetSocket, io.vertx.proton.impl.ProtonSaslClientAuthenticatorImpl, io.vertx.proton.ProtonTransportOptions);
descriptor: (Lio/vertx/core/net/NetClient;Lio/vertx/core/net/NetSocket;Lio/vertx/proton/impl/ProtonSaslClientAuthenticatorImpl;Lio/vertx/proton/ProtonTransportOptions;)V
flags: (0x0000)
Code:
stack=9, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
new io.vertx.proton.impl.ProtonTransport
dup
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.vertx:Lio/vertx/core/Vertx;
aload 1
aload 2
aload 3
aload 4
invokespecial io.vertx.proton.impl.ProtonTransport.<init>:(Lorg/apache/qpid/proton/engine/Connection;Lio/vertx/core/Vertx;Lio/vertx/core/net/NetClient;Lio/vertx/core/net/NetSocket;Lio/vertx/proton/sasl/ProtonSaslAuthenticator;Lio/vertx/proton/ProtonTransportOptions;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 2 1 client Lio/vertx/core/net/NetClient;
0 2 2 socket Lio/vertx/core/net/NetSocket;
0 2 3 authenticator Lio/vertx/proton/impl/ProtonSaslClientAuthenticatorImpl;
0 2 4 transportOptions Lio/vertx/proton/ProtonTransportOptions;
MethodParameters:
Name Flags
client
socket
authenticator
transportOptions
void bindServer(io.vertx.core.net.NetSocket, io.vertx.proton.sasl.ProtonSaslAuthenticator, io.vertx.proton.ProtonTransportOptions);
descriptor: (Lio/vertx/core/net/NetSocket;Lio/vertx/proton/sasl/ProtonSaslAuthenticator;Lio/vertx/proton/ProtonTransportOptions;)V
flags: (0x0000)
Code:
stack=9, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
new io.vertx.proton.impl.ProtonTransport
dup
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connection:Lorg/apache/qpid/proton/engine/Connection;
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.vertx:Lio/vertx/core/Vertx;
aconst_null
aload 1
aload 2
aload 3
invokespecial io.vertx.proton.impl.ProtonTransport.<init>:(Lorg/apache/qpid/proton/engine/Connection;Lio/vertx/core/Vertx;Lio/vertx/core/net/NetClient;Lio/vertx/core/net/NetSocket;Lio/vertx/proton/sasl/ProtonSaslAuthenticator;Lio/vertx/proton/ProtonTransportOptions;)V
putfield io.vertx.proton.impl.ProtonConnectionImpl.transport:Lio/vertx/proton/impl/ProtonTransport;
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 2 1 socket Lio/vertx/core/net/NetSocket;
0 2 2 authenticator Lio/vertx/proton/sasl/ProtonSaslAuthenticator;
0 2 3 transportOptions Lio/vertx/proton/ProtonTransportOptions;
MethodParameters:
Name Flags
socket
authenticator
transportOptions
void fireRemoteSessionOpen(org.apache.qpid.proton.engine.Session);
descriptor: (Lorg/apache/qpid/proton/engine/Session;)V
flags: (0x0000)
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.sessionOpenHandler:Lio/vertx/core/Handler;
ifnull 2
1: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.sessionOpenHandler:Lio/vertx/core/Handler;
new io.vertx.proton.impl.ProtonSessionImpl
dup
aload 1
invokespecial io.vertx.proton.impl.ProtonSessionImpl.<init>:(Lorg/apache/qpid/proton/engine/Session;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 3 1 session Lorg/apache/qpid/proton/engine/Session;
MethodParameters:
Name Flags
session
void fireRemoteLinkOpen(org.apache.qpid.proton.engine.Link);
descriptor: (Lorg/apache/qpid/proton/engine/Link;)V
flags: (0x0000)
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
instanceof org.apache.qpid.proton.engine.Sender
ifeq 4
1: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.senderOpenHandler:Lio/vertx/core/Handler;
ifnull 6
2: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.senderOpenHandler:Lio/vertx/core/Handler;
new io.vertx.proton.impl.ProtonSenderImpl
dup
aload 1
checkcast org.apache.qpid.proton.engine.Sender
invokespecial io.vertx.proton.impl.ProtonSenderImpl.<init>:(Lorg/apache/qpid/proton/engine/Sender;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: goto 6
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.receiverOpenHandler:Lio/vertx/core/Handler;
ifnull 6
5: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.receiverOpenHandler:Lio/vertx/core/Handler;
new io.vertx.proton.impl.ProtonReceiverImpl
dup
aload 1
checkcast org.apache.qpid.proton.engine.Receiver
invokespecial io.vertx.proton.impl.ProtonReceiverImpl.<init>:(Lorg/apache/qpid/proton/engine/Receiver;)V
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 7 1 link Lorg/apache/qpid/proton/engine/Link;
MethodParameters:
Name Flags
link
public void addEndHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.endHandlers: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/proton/impl/ProtonConnectionImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
handler
public io.vertx.core.impl.ContextInternal getContext();
descriptor: ()Lio/vertx/core/impl/ContextInternal;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.connCtx:Lio/vertx/core/impl/ContextInternal;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
public io.vertx.proton.ProtonConnection setProperties(java.util.Map);
descriptor: (Ljava/util/Map;)Lio/vertx/proton/ProtonConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.setProperties:(Ljava/util/Map;)Lio/vertx/proton/impl/ProtonConnectionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonConnection setContainer(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/proton/ProtonConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.setContainer:(Ljava/lang/String;)Lio/vertx/proton/impl/ProtonConnectionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonConnection setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition);
descriptor: (Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/ProtonConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.setCondition:(Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/impl/ProtonConnectionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonConnection setOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[]);
descriptor: ([Lorg/apache/qpid/proton/amqp/Symbol;)Lio/vertx/proton/ProtonConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.setOfferedCapabilities:([Lorg/apache/qpid/proton/amqp/Symbol;)Lio/vertx/proton/impl/ProtonConnectionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonSession createSession();
descriptor: ()Lio/vertx/proton/ProtonSession;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.createSession:()Lio/vertx/proton/impl/ProtonSessionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonConnection setDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[]);
descriptor: ([Lorg/apache/qpid/proton/amqp/Symbol;)Lio/vertx/proton/ProtonConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.setDesiredCapabilities:([Lorg/apache/qpid/proton/amqp/Symbol;)Lio/vertx/proton/impl/ProtonConnectionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonConnection setHostname(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/proton/ProtonConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.setHostname:(Ljava/lang/String;)Lio/vertx/proton/impl/ProtonConnectionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$0(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic io.vertx.proton.impl.ProtonConnectionImpl.LOG:Lio/vertx/core/logging/Logger;
ldc "Connection open completed"
invokevirtual io.vertx.core.logging.Logger.trace:(Ljava/lang/Object;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 result Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;
private static void lambda$1(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic io.vertx.proton.impl.ProtonConnectionImpl.LOG:Lio/vertx/core/logging/Logger;
ldc "Connection closed"
invokevirtual io.vertx.core.logging.Logger.trace:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
getstatic io.vertx.proton.impl.ProtonConnectionImpl.LOG:Lio/vertx/core/logging/Logger;
ldc "Connection closed with error"
aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.logging.Logger.warn:(Ljava/lang/Object;Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 result Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;
private static void lambda$2(io.vertx.proton.ProtonConnection);
descriptor: (Lio/vertx/proton/ProtonConnection;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic io.vertx.proton.impl.ProtonConnectionImpl.LOG:Lio/vertx/core/logging/Logger;
ldc "Connection disconnected"
invokevirtual io.vertx.core.logging.Logger.trace:(Ljava/lang/Object;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 connection Lio/vertx/proton/ProtonConnection;
private static void lambda$3(io.vertx.proton.ProtonSession);
descriptor: (Lio/vertx/proton/ProtonSession;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
new org.apache.qpid.proton.amqp.transport.ErrorCondition
dup
ldc "Not Supported"
invokestatic org.apache.qpid.proton.amqp.Symbol.getSymbol:(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol;
ldc ""
invokespecial org.apache.qpid.proton.amqp.transport.ErrorCondition.<init>:(Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/String;)V
invokeinterface io.vertx.proton.ProtonSession.setCondition:(Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/ProtonSession;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 session Lio/vertx/proton/ProtonSession;
private static void lambda$4(io.vertx.proton.ProtonSender);
descriptor: (Lio/vertx/proton/ProtonSender;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
new org.apache.qpid.proton.amqp.transport.ErrorCondition
dup
ldc "Not Supported"
invokestatic org.apache.qpid.proton.amqp.Symbol.getSymbol:(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol;
ldc ""
invokespecial org.apache.qpid.proton.amqp.transport.ErrorCondition.<init>:(Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/String;)V
invokeinterface io.vertx.proton.ProtonSender.setCondition:(Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/ProtonLink;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 sender Lio/vertx/proton/ProtonSender;
private static void lambda$5(io.vertx.proton.ProtonReceiver);
descriptor: (Lio/vertx/proton/ProtonReceiver;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
new org.apache.qpid.proton.amqp.transport.ErrorCondition
dup
ldc "Not Supported"
invokestatic org.apache.qpid.proton.amqp.Symbol.getSymbol:(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol;
ldc ""
invokespecial org.apache.qpid.proton.amqp.transport.ErrorCondition.<init>:(Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/String;)V
invokeinterface io.vertx.proton.ProtonReceiver.setCondition:(Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/ProtonLink;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 receiver Lio/vertx/proton/ProtonReceiver;
private void lambda$6(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: ldc "The connections default session closed unexpectedly"
astore 2
start local 2 1: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifne 4
2: 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;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 2
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.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)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: StackMap locals: java.lang.String
StackMap stack:
aload 2
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
astore 3
start local 3 5: aload 0
getfield io.vertx.proton.impl.ProtonConnectionImpl.closeHandler:Lio/vertx/core/Handler;
astore 4
start local 4 6: aload 4
ifnull 8
7: aload 4
aload 3
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 4 end local 3 end local 2 8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/proton/impl/ProtonConnectionImpl;
0 9 1 result Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonSession;>;
1 8 2 msg Ljava/lang/String;
5 8 3 failure Lio/vertx/core/Future<Lio/vertx/proton/ProtonConnection;>;
6 8 4 connCloseHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/proton/ProtonConnection;>;>;
}
SourceFile: "ProtonConnectionImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles