public class io.vertx.proton.impl.ProtonSenderImpl extends io.vertx.proton.impl.ProtonLinkImpl<io.vertx.proton.ProtonSender> implements io.vertx.proton.ProtonSender
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.proton.impl.ProtonSenderImpl
super_class: io.vertx.proton.impl.ProtonLinkImpl
{
private io.vertx.core.Handler<io.vertx.proton.ProtonSender> drainHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSender;>;
private boolean anonymousSender;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean autoSettle;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private int tag;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private boolean autoDrained;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
void <init>(org.apache.qpid.proton.engine.Sender);
descriptor: (Lorg/apache/qpid/proton/engine/Sender;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.<init>:(Lorg/apache/qpid/proton/engine/Link;)V
1: aload 0
iconst_1
putfield io.vertx.proton.impl.ProtonSenderImpl.autoSettle:Z
2: aload 0
iconst_1
putfield io.vertx.proton.impl.ProtonSenderImpl.tag:I
3: aload 0
iconst_1
putfield io.vertx.proton.impl.ProtonSenderImpl.autoDrained:Z
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 5 1 sender Lorg/apache/qpid/proton/engine/Sender;
MethodParameters:
Name Flags
sender
private org.apache.qpid.proton.engine.Sender sender();
descriptor: ()Lorg/apache/qpid/proton/engine/Sender;
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.link:Lorg/apache/qpid/proton/engine/Link;
checkcast org.apache.qpid.proton.engine.Sender
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
public io.vertx.proton.ProtonDelivery send(org.apache.qpid.proton.message.Message);
descriptor: (Lorg/apache/qpid/proton/message/Message;)Lio/vertx/proton/ProtonDelivery;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aconst_null
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.send:(Lorg/apache/qpid/proton/message/Message;Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonDelivery;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 1 1 message Lorg/apache/qpid/proton/message/Message;
MethodParameters:
Name Flags
message
public io.vertx.proton.ProtonDelivery send(org.apache.qpid.proton.message.Message, io.vertx.core.Handler<io.vertx.proton.ProtonDelivery>);
descriptor: (Lorg/apache/qpid/proton/message/Message;Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonDelivery;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.generateTag:()[B
aload 1
aload 2
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.send:([BLorg/apache/qpid/proton/message/Message;Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonDelivery;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 1 1 message Lorg/apache/qpid/proton/message/Message;
0 1 2 onUpdated Lio/vertx/core/Handler<Lio/vertx/proton/ProtonDelivery;>;
Signature: (Lorg/apache/qpid/proton/message/Message;Lio/vertx/core/Handler<Lio/vertx/proton/ProtonDelivery;>;)Lio/vertx/proton/ProtonDelivery;
MethodParameters:
Name Flags
message
onUpdated
private byte[] generateTag();
descriptor: ()[B
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
dup
getfield io.vertx.proton.impl.ProtonSenderImpl.tag:I
dup_x1
iconst_1
iadd
putfield io.vertx.proton.impl.ProtonSenderImpl.tag:I
istore 1
start local 1 1: iconst_4
newarray 8
astore 2
start local 2 2: aload 2
iload 1
invokestatic io.vertx.proton.impl.ProtonSenderImpl.setInt:([BI)V
3: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
1 4 1 value I
2 4 2 binary [B
private static void setInt(byte[], int);
descriptor: ([BI)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iconst_0
iload 1
bipush 24
iushr
i2b
bastore
1: aload 0
iconst_1
iload 1
bipush 16
iushr
i2b
bastore
2: aload 0
iconst_2
iload 1
bipush 8
iushr
i2b
bastore
3: aload 0
iconst_3
iload 1
i2b
bastore
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 binary [B
0 5 1 value I
MethodParameters:
Name Flags
binary
value
public io.vertx.proton.ProtonDelivery send(byte[], org.apache.qpid.proton.message.Message);
descriptor: ([BLorg/apache/qpid/proton/message/Message;)Lio/vertx/proton/ProtonDelivery;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
aconst_null
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.send:([BLorg/apache/qpid/proton/message/Message;Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonDelivery;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 1 1 tag [B
0 1 2 message Lorg/apache/qpid/proton/message/Message;
MethodParameters:
Name Flags
tag
message
public io.vertx.proton.ProtonDelivery send(byte[], org.apache.qpid.proton.message.Message, io.vertx.core.Handler<io.vertx.proton.ProtonDelivery>);
descriptor: ([BLorg/apache/qpid/proton/message/Message;Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonDelivery;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.anonymousSender:Z
ifeq 2
aload 2
invokeinterface org.apache.qpid.proton.message.Message.getAddress:()Ljava/lang/String;
ifnonnull 2
1: new java.lang.IllegalArgumentException
dup
ldc "Message must have an address when using anonymous sender."
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.sender:()Lorg/apache/qpid/proton/engine/Sender;
aload 1
invokeinterface org.apache.qpid.proton.engine.Sender.delivery:([B)Lorg/apache/qpid/proton/engine/Delivery;
astore 4
start local 4 3: new io.vertx.proton.impl.ProtonWritableBufferImpl
dup
invokespecial io.vertx.proton.impl.ProtonWritableBufferImpl.<init>:()V
astore 5
start local 5 4: aload 2
checkcast org.apache.qpid.proton.message.impl.MessageImpl
astore 6
start local 6 5: aload 6
aload 5
invokevirtual org.apache.qpid.proton.message.impl.MessageImpl.encode:(Lorg/apache/qpid/proton/codec/WritableBuffer;)I
pop
6: new io.vertx.proton.impl.ProtonReadableBufferImpl
dup
aload 5
invokevirtual io.vertx.proton.impl.ProtonWritableBufferImpl.getBuffer:()Lio/netty/buffer/ByteBuf;
invokespecial io.vertx.proton.impl.ProtonReadableBufferImpl.<init>:(Lio/netty/buffer/ByteBuf;)V
astore 7
start local 7 7: aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.sender:()Lorg/apache/qpid/proton/engine/Sender;
aload 7
invokeinterface org.apache.qpid.proton.engine.Sender.sendNoCopy:(Lorg/apache/qpid/proton/codec/ReadableBuffer;)I
pop
8: aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.link:Lorg/apache/qpid/proton/engine/Link;
invokeinterface org.apache.qpid.proton.engine.Link.getSenderSettleMode:()Lorg/apache/qpid/proton/amqp/transport/SenderSettleMode;
getstatic org.apache.qpid.proton.amqp.transport.SenderSettleMode.SETTLED:Lorg/apache/qpid/proton/amqp/transport/SenderSettleMode;
if_acmpne 10
9: aload 4
invokeinterface org.apache.qpid.proton.engine.Delivery.settle:()V
10: StackMap locals: io.vertx.proton.impl.ProtonSenderImpl byte[] org.apache.qpid.proton.message.Message io.vertx.core.Handler org.apache.qpid.proton.engine.Delivery io.vertx.proton.impl.ProtonWritableBufferImpl org.apache.qpid.proton.message.impl.MessageImpl org.apache.qpid.proton.codec.ReadableBuffer
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.sender:()Lorg/apache/qpid/proton/engine/Sender;
invokeinterface org.apache.qpid.proton.engine.Sender.advance:()Z
pop
11: new io.vertx.proton.impl.ProtonDeliveryImpl
dup
aload 4
invokespecial io.vertx.proton.impl.ProtonDeliveryImpl.<init>:(Lorg/apache/qpid/proton/engine/Delivery;)V
astore 8
start local 8 12: aload 3
ifnull 16
13: aload 8
aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.autoSettle:Z
invokevirtual io.vertx.proton.impl.ProtonDeliveryImpl.setAutoSettle:(Z)V
14: aload 8
aload 3
invokevirtual io.vertx.proton.impl.ProtonDeliveryImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonDelivery;
pop
15: goto 17
16: StackMap locals: io.vertx.proton.impl.ProtonDeliveryImpl
StackMap stack:
aload 8
iconst_1
invokevirtual io.vertx.proton.impl.ProtonDeliveryImpl.setAutoSettle:(Z)V
17: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.getSession:()Lio/vertx/proton/impl/ProtonSessionImpl;
invokevirtual io.vertx.proton.impl.ProtonSessionImpl.getConnectionImpl:()Lio/vertx/proton/impl/ProtonConnectionImpl;
invokevirtual io.vertx.proton.impl.ProtonConnectionImpl.flush:()V
18: aload 8
areturn
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 19 1 tag [B
0 19 2 message Lorg/apache/qpid/proton/message/Message;
0 19 3 onUpdated Lio/vertx/core/Handler<Lio/vertx/proton/ProtonDelivery;>;
3 19 4 delivery Lorg/apache/qpid/proton/engine/Delivery;
4 19 5 buffer Lio/vertx/proton/impl/ProtonWritableBufferImpl;
5 19 6 msg Lorg/apache/qpid/proton/message/impl/MessageImpl;
7 19 7 encoded Lorg/apache/qpid/proton/codec/ReadableBuffer;
12 19 8 protonDeliveryImpl Lio/vertx/proton/impl/ProtonDeliveryImpl;
Signature: ([BLorg/apache/qpid/proton/message/Message;Lio/vertx/core/Handler<Lio/vertx/proton/ProtonDelivery;>;)Lio/vertx/proton/ProtonDelivery;
MethodParameters:
Name Flags
tag
message
onUpdated
public boolean isAutoSettle();
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.ProtonSenderImpl.autoSettle:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
public io.vertx.proton.ProtonSender setAutoSettle(boolean);
descriptor: (Z)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
iload 1
putfield io.vertx.proton.impl.ProtonSenderImpl.autoSettle:Z
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 2 1 autoSettle Z
MethodParameters:
Name Flags
autoSettle
boolean isAnonymousSender();
descriptor: ()Z
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.anonymousSender:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
void setAnonymousSender(boolean);
descriptor: (Z)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield io.vertx.proton.impl.ProtonSenderImpl.anonymousSender:Z
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 2 1 anonymousSender Z
MethodParameters:
Name Flags
anonymousSender
protected io.vertx.proton.impl.ProtonSenderImpl self();
descriptor: ()Lio/vertx/proton/impl/ProtonSenderImpl;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
public boolean sendQueueFull();
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.ProtonSenderImpl.link:Lorg/apache/qpid/proton/engine/Link;
invokeinterface org.apache.qpid.proton.engine.Link.getRemoteCredit:()I
ifgt 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/ProtonSenderImpl;
public io.vertx.proton.ProtonSender sendQueueDrainHandler(io.vertx.core.Handler<io.vertx.proton.ProtonSender>);
descriptor: (Lio/vertx/core/Handler;)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
aload 1
putfield io.vertx.proton.impl.ProtonSenderImpl.drainHandler:Lio/vertx/core/Handler;
1: aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.handleLinkFlow:()V
2: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 3 1 drainHandler Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSender;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/proton/ProtonSender;>;)Lio/vertx/proton/ProtonSender;
MethodParameters:
Name Flags
drainHandler
void handleLinkFlow();
descriptor: ()V
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.link:Lorg/apache/qpid/proton/engine/Link;
invokeinterface org.apache.qpid.proton.engine.Link.getRemoteCredit:()I
ifle 2
aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.drainHandler:Lio/vertx/core/Handler;
ifnull 2
1: aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.drainHandler:Lio/vertx/core/Handler;
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonSenderImpl.autoDrained:Z
ifeq 4
aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.getDrain:()Z
ifeq 4
3: aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.drained:()I
pop
4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
public boolean isAutoDrained();
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.ProtonSenderImpl.autoDrained:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
public io.vertx.proton.ProtonSender setAutoDrained(boolean);
descriptor: (Z)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
iload 1
putfield io.vertx.proton.impl.ProtonSenderImpl.autoDrained:Z
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
0 2 1 autoDrained Z
MethodParameters:
Name Flags
autoDrained
public int drained();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.drained:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
public java.lang.String getRemoteAddress();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.getRemoteTarget:()Lorg/apache/qpid/proton/amqp/transport/Target;
astore 1
start local 1 1: aload 1
ifnonnull 2
aconst_null
goto 3
StackMap locals: org.apache.qpid.proton.amqp.transport.Target
StackMap stack:
2: aload 1
invokeinterface org.apache.qpid.proton.amqp.transport.Target.getAddress:()Ljava/lang/String;
StackMap locals:
StackMap stack: java.lang.String
3: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/proton/impl/ProtonSenderImpl;
1 4 1 remoteTarget Lorg/apache/qpid/proton/amqp/transport/Target;
public void setOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[]);
descriptor: ([Lorg/apache/qpid/proton/amqp/Symbol;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setOfferedCapabilities:([Lorg/apache/qpid/proton/amqp/Symbol;)V
return
LocalVariableTable:
Start End Slot Name Signature
public boolean isOpen();
descriptor: ()Z
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.isOpen:()Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
public boolean getDrain();
descriptor: ()Z
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getDrain:()Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
public void setProperties(java.util.Map);
descriptor: (Ljava/util/Map;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setProperties:(Ljava/util/Map;)V
return
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.Symbol[] getRemoteDesiredCapabilities();
descriptor: ()[Lorg/apache/qpid/proton/amqp/Symbol;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteDesiredCapabilities:()[Lorg/apache/qpid/proton/amqp/Symbol;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.UnsignedLong getRemoteMaxMessageSize();
descriptor: ()Lorg/apache/qpid/proton/amqp/UnsignedLong;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteMaxMessageSize:()Lorg/apache/qpid/proton/amqp/UnsignedLong;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink setSource(org.apache.qpid.proton.amqp.transport.Source);
descriptor: (Lorg/apache/qpid/proton/amqp/transport/Source;)Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setSource:(Lorg/apache/qpid/proton/amqp/transport/Source;)Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.transport.Source getRemoteSource();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Source;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteSource:()Lorg/apache/qpid/proton/amqp/transport/Source;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.transport.Target getTarget();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Target;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getTarget:()Lorg/apache/qpid/proton/amqp/transport/Target;
areturn
LocalVariableTable:
Start End Slot Name Signature
public void setDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[]);
descriptor: ([Lorg/apache/qpid/proton/amqp/Symbol;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setDesiredCapabilities:([Lorg/apache/qpid/proton/amqp/Symbol;)V
return
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.transport.ErrorCondition getCondition();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink open();
descriptor: ()Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.open:()Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink closeHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink detach();
descriptor: ()Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.detach:()Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink detachHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.detachHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public int getUnsettled();
descriptor: ()I
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getUnsettled:()I
ireturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.engine.Record attachments();
descriptor: ()Lorg/apache/qpid/proton/engine/Record;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.attachments:()Lorg/apache/qpid/proton/engine/Record;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition);
descriptor: (Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setCondition:(Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
protected io.vertx.proton.ProtonLink self();
descriptor: ()Lio/vertx/proton/ProtonLink;
flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.proton.impl.ProtonSenderImpl.self:()Lio/vertx/proton/impl/ProtonSenderImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.transport.Source getSource();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Source;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getSource:()Lorg/apache/qpid/proton/amqp/transport/Source;
areturn
LocalVariableTable:
Start End Slot Name Signature
public boolean detached();
descriptor: ()Z
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.detached:()Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.engine.EndpointState getLocalState();
descriptor: ()Lorg/apache/qpid/proton/engine/EndpointState;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getLocalState:()Lorg/apache/qpid/proton/engine/EndpointState;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink setQoS(io.vertx.proton.ProtonQoS);
descriptor: (Lio/vertx/proton/ProtonQoS;)Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setQoS:(Lio/vertx/proton/ProtonQoS;)Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.transport.ErrorCondition getRemoteCondition();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteCondition:()Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.engine.Delivery current();
descriptor: ()Lorg/apache/qpid/proton/engine/Delivery;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.current:()Lorg/apache/qpid/proton/engine/Delivery;
areturn
LocalVariableTable:
Start End Slot Name Signature
public int getRemoteCredit();
descriptor: ()I
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteCredit:()I
ireturn
LocalVariableTable:
Start End Slot Name Signature
public int getQueued();
descriptor: ()I
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getQueued:()I
ireturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink openHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.openHandler:(Lio/vertx/core/Handler;)Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink close();
descriptor: ()Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.close:()Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public java.util.Map getRemoteProperties();
descriptor: ()Ljava/util/Map;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteProperties:()Ljava/util/Map;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.impl.ProtonSessionImpl getSession();
descriptor: ()Lio/vertx/proton/impl/ProtonSessionImpl;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getSession:()Lio/vertx/proton/impl/ProtonSessionImpl;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonQoS getRemoteQoS();
descriptor: ()Lio/vertx/proton/ProtonQoS;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteQoS:()Lio/vertx/proton/ProtonQoS;
areturn
LocalVariableTable:
Start End Slot Name Signature
public java.lang.String getName();
descriptor: ()Ljava/lang/String;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getName:()Ljava/lang/String;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.UnsignedLong getMaxMessageSize();
descriptor: ()Lorg/apache/qpid/proton/amqp/UnsignedLong;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getMaxMessageSize:()Lorg/apache/qpid/proton/amqp/UnsignedLong;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.engine.Delivery delivery(byte[]);
descriptor: ([B)Lorg/apache/qpid/proton/engine/Delivery;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.delivery:([B)Lorg/apache/qpid/proton/engine/Delivery;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.engine.Delivery delivery(byte[], int, int);
descriptor: ([BII)Lorg/apache/qpid/proton/engine/Delivery;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
iload 2
iload 3
invokespecial io.vertx.proton.impl.ProtonLinkImpl.delivery:([BII)Lorg/apache/qpid/proton/engine/Delivery;
areturn
LocalVariableTable:
Start End Slot Name Signature
public int getCredit();
descriptor: ()I
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getCredit:()I
ireturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonQoS getQoS();
descriptor: ()Lio/vertx/proton/ProtonQoS;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getQoS:()Lio/vertx/proton/ProtonQoS;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.Symbol[] getRemoteOfferedCapabilities();
descriptor: ()[Lorg/apache/qpid/proton/amqp/Symbol;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteOfferedCapabilities:()[Lorg/apache/qpid/proton/amqp/Symbol;
areturn
LocalVariableTable:
Start End Slot Name Signature
public void free();
descriptor: ()V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.free:()V
return
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.proton.ProtonLink setTarget(org.apache.qpid.proton.amqp.transport.Target);
descriptor: (Lorg/apache/qpid/proton/amqp/transport/Target;)Lio/vertx/proton/ProtonLink;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setTarget:(Lorg/apache/qpid/proton/amqp/transport/Target;)Lio/vertx/proton/ProtonLink;
areturn
LocalVariableTable:
Start End Slot Name Signature
public void setMaxMessageSize(org.apache.qpid.proton.amqp.UnsignedLong);
descriptor: (Lorg/apache/qpid/proton/amqp/UnsignedLong;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.proton.impl.ProtonLinkImpl.setMaxMessageSize:(Lorg/apache/qpid/proton/amqp/UnsignedLong;)V
return
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.amqp.transport.Target getRemoteTarget();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Target;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteTarget:()Lorg/apache/qpid/proton/amqp/transport/Target;
areturn
LocalVariableTable:
Start End Slot Name Signature
public boolean advance();
descriptor: ()Z
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.advance:()Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.qpid.proton.engine.EndpointState getRemoteState();
descriptor: ()Lorg/apache/qpid/proton/engine/EndpointState;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.getRemoteState:()Lorg/apache/qpid/proton/engine/EndpointState;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Lio/vertx/proton/impl/ProtonLinkImpl<Lio/vertx/proton/ProtonSender;>;Lio/vertx/proton/ProtonSender;
SourceFile: "ProtonSenderImpl.java"