public class io.vertx.proton.impl.ProtonReceiverImpl extends io.vertx.proton.impl.ProtonLinkImpl<io.vertx.proton.ProtonReceiver> implements io.vertx.proton.ProtonReceiver
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.proton.impl.ProtonReceiverImpl
super_class: io.vertx.proton.impl.ProtonLinkImpl
{
private static final io.vertx.core.logging.Logger LOG;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private io.vertx.proton.ProtonMessageHandler handler;
descriptor: Lio/vertx/proton/ProtonMessageHandler;
flags: (0x0002) ACC_PRIVATE
private int prefetch;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> drainCompleteHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
private java.lang.Long drainTimeoutTaskId;
descriptor: Ljava/lang/Long;
flags: (0x0002) ACC_PRIVATE
private org.apache.qpid.proton.engine.Session session;
descriptor: Lorg/apache/qpid/proton/engine/Session;
flags: (0x0002) ACC_PRIVATE
private int maxFrameSize;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private long sessionIncomingCapacity;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long windowFullThreshhold;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private boolean autoAccept;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private org.apache.qpid.proton.codec.CompositeReadableBuffer splitContent;
descriptor: Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
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/ProtonReceiverImpl;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.proton.impl.ProtonReceiverImpl.LOG:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(org.apache.qpid.proton.engine.Receiver);
descriptor: (Lorg/apache/qpid/proton/engine/Receiver;)V
flags: (0x0000)
Code:
stack=5, 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
sipush 1000
putfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
2: aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonReceiverImpl.drainTimeoutTaskId:Ljava/lang/Long;
3: aload 0
iconst_1
putfield io.vertx.proton.impl.ProtonReceiverImpl.autoAccept:Z
4: aload 0
aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.getSession:()Lorg/apache/qpid/proton/engine/Session;
putfield io.vertx.proton.impl.ProtonReceiverImpl.session:Lorg/apache/qpid/proton/engine/Session;
5: aload 0
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.session:Lorg/apache/qpid/proton/engine/Session;
invokeinterface org.apache.qpid.proton.engine.Session.getIncomingCapacity:()I
i2l
putfield io.vertx.proton.impl.ProtonReceiverImpl.sessionIncomingCapacity:J
6: aload 0
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.session:Lorg/apache/qpid/proton/engine/Session;
invokeinterface org.apache.qpid.proton.engine.Session.getConnection:()Lorg/apache/qpid/proton/engine/Connection;
invokeinterface org.apache.qpid.proton.engine.Connection.getTransport:()Lorg/apache/qpid/proton/engine/Transport;
invokeinterface org.apache.qpid.proton.engine.Transport.getMaxFrameSize:()I
putfield io.vertx.proton.impl.ProtonReceiverImpl.maxFrameSize:I
7: aload 0
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.sessionIncomingCapacity:J
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.maxFrameSize:I
i2l
lsub
putfield io.vertx.proton.impl.ProtonReceiverImpl.windowFullThreshhold:J
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 9 1 receiver Lorg/apache/qpid/proton/engine/Receiver;
MethodParameters:
Name Flags
receiver
protected io.vertx.proton.impl.ProtonReceiverImpl self();
descriptor: ()Lio/vertx/proton/impl/ProtonReceiverImpl;
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/ProtonReceiverImpl;
private org.apache.qpid.proton.engine.Receiver getReceiver();
descriptor: ()Lorg/apache/qpid/proton/engine/Receiver;
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.link:Lorg/apache/qpid/proton/engine/Link;
checkcast org.apache.qpid.proton.engine.Receiver
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
public int recv(byte[], int, int);
descriptor: ([BII)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getReceiver:()Lorg/apache/qpid/proton/engine/Receiver;
aload 1
iload 2
iload 3
invokeinterface org.apache.qpid.proton.engine.Receiver.recv:([BII)I
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 1 1 bytes [B
0 1 2 offset I
0 1 3 size I
MethodParameters:
Name Flags
bytes
offset
size
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.ProtonReceiverImpl.getRemoteSource:()Lorg/apache/qpid/proton/amqp/transport/Source;
astore 1
start local 1 1: aload 1
ifnonnull 2
aconst_null
goto 3
StackMap locals: org.apache.qpid.proton.amqp.transport.Source
StackMap stack:
2: aload 1
invokeinterface org.apache.qpid.proton.amqp.transport.Source.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/ProtonReceiverImpl;
1 4 1 remoteSource Lorg/apache/qpid/proton/amqp/transport/Source;
public io.vertx.proton.ProtonReceiver drain(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (JLio/vertx/core/Handler;)Lio/vertx/proton/ProtonReceiver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
ifle 2
1: new java.lang.IllegalStateException
dup
ldc "Manual credit management not available while prefetch is non-zero"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 3
ifnonnull 4
3: new java.lang.IllegalArgumentException
dup
ldc "A completion handler must be provided"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.drainCompleteHandler:Lio/vertx/core/Handler;
ifnull 6
5: new java.lang.IllegalStateException
dup
ldc "A previous drain operation has not yet completed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getCredit:()I
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getQueued:()I
isub
ifgt 12
7: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getQueued:()I
ifne 10
8: aload 3
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
9: goto 15
10: StackMap locals:
StackMap stack:
aload 0
lload 1
aload 3
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.setDrainHandlerAndTimeoutTask:(JLio/vertx/core/Handler;)V
11: goto 15
12: StackMap locals:
StackMap stack:
aload 0
lload 1
aload 3
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.setDrainHandlerAndTimeoutTask:(JLio/vertx/core/Handler;)V
13: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getReceiver:()Lorg/apache/qpid/proton/engine/Receiver;
iconst_0
invokeinterface org.apache.qpid.proton.engine.Receiver.drain:(I)V
14: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.flushConnection:()V
15: StackMap locals:
StackMap stack:
aload 0
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 16 1 timeout J
0 16 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/proton/ProtonReceiver;
MethodParameters:
Name Flags
timeout
completionHandler
private void setDrainHandlerAndTimeoutTask(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (JLio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=3
start local 0 start local 1 start local 3 0: aload 0
aload 3
putfield io.vertx.proton.impl.ProtonReceiverImpl.drainCompleteHandler:Lio/vertx/core/Handler;
1: lload 1
lconst_0
lcmp
ifle 4
2: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
invokeinterface io.vertx.core.Context.owner:()Lio/vertx/core/Vertx;
astore 4
start local 4 3: aload 0
aload 4
lload 1
aload 0
aload 3
invokedynamic handle(Lio/vertx/proton/impl/ProtonReceiverImpl;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/proton/impl/ProtonReceiverImpl.lambda$0(Lio/vertx/core/Handler;Ljava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
putfield io.vertx.proton.impl.ProtonReceiverImpl.drainTimeoutTaskId:Ljava/lang/Long;
end local 4 4: StackMap locals:
StackMap stack:
return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 5 1 delay J
0 5 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
3 4 4 vertx Lio/vertx/core/Vertx;
Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
delay
completionHandler
public io.vertx.proton.ProtonReceiver flow(int);
descriptor: (I)Lio/vertx/proton/ProtonReceiver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
iconst_1
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.flow:(IZ)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/ProtonReceiverImpl;
0 2 1 credits I
Exceptions:
throws java.lang.IllegalStateException
MethodParameters:
Name Flags
credits
private void flow(int, boolean);
descriptor: (IZ)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 2
ifeq 2
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
ifle 2
1: new java.lang.IllegalStateException
dup
ldc "Manual credit management not available while prefetch is non-zero"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.drainCompleteHandler:Lio/vertx/core/Handler;
ifnull 4
3: new java.lang.IllegalStateException
dup
ldc "A previous drain operation has not yet completed"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getReceiver:()Lorg/apache/qpid/proton/engine/Receiver;
iload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.flow:(I)V
5: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.flushConnection:()V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 7 1 credits I
0 7 2 checkPrefetch Z
Exceptions:
throws java.lang.IllegalStateException
MethodParameters:
Name Flags
credits
checkPrefetch
public boolean draining();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getReceiver:()Lorg/apache/qpid/proton/engine/Receiver;
invokeinterface org.apache.qpid.proton.engine.Receiver.draining:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
public io.vertx.proton.ProtonReceiver setDrain(boolean);
descriptor: (Z)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.ProtonReceiverImpl.getReceiver:()Lorg/apache/qpid/proton/engine/Receiver;
iload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.setDrain:(Z)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/ProtonReceiverImpl;
0 2 1 drain Z
MethodParameters:
Name Flags
drain
public io.vertx.proton.ProtonReceiver handler(io.vertx.proton.ProtonMessageHandler);
descriptor: (Lio/vertx/proton/ProtonMessageHandler;)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
aload 1
putfield io.vertx.proton.impl.ProtonReceiverImpl.handler:Lio/vertx/proton/ProtonMessageHandler;
1: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.onDelivery:()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/ProtonReceiverImpl;
0 3 1 handler Lio/vertx/proton/ProtonMessageHandler;
MethodParameters:
Name Flags
handler
private void flushConnection();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.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
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
void onDelivery();
descriptor: ()V
flags: (0x0000)
Code:
stack=3, locals=7, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.handler:Lio/vertx/proton/ProtonMessageHandler;
ifnonnull 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getReceiver:()Lorg/apache/qpid/proton/engine/Receiver;
astore 1
start local 1 3: aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.current:()Lorg/apache/qpid/proton/engine/Delivery;
astore 2
start local 2 4: aload 2
ifnull 30
5: aload 2
invokeinterface org.apache.qpid.proton.engine.Delivery.isAborted:()Z
ifeq 8
6: aload 0
aload 1
aload 2
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.handleAborted:(Lorg/apache/qpid/proton/engine/Receiver;Lorg/apache/qpid/proton/engine/Delivery;)V
7: return
8: StackMap locals: org.apache.qpid.proton.engine.Receiver org.apache.qpid.proton.engine.Delivery
StackMap stack:
aload 2
invokeinterface org.apache.qpid.proton.engine.Delivery.isPartial:()Z
ifeq 11
9: aload 0
aload 1
aload 2
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.handlePartial:(Lorg/apache/qpid/proton/engine/Receiver;Lorg/apache/qpid/proton/engine/Delivery;)V
10: return
11: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.recv:()Lorg/apache/qpid/proton/codec/ReadableBuffer;
astore 3
start local 3 12: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
ifnull 14
13: aload 0
aload 3
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.completePartial:(Lorg/apache/qpid/proton/codec/ReadableBuffer;)Lorg/apache/qpid/proton/codec/ReadableBuffer;
astore 3
14: StackMap locals: org.apache.qpid.proton.codec.ReadableBuffer
StackMap stack:
aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.advance:()Z
pop
15: invokestatic org.apache.qpid.proton.Proton.message:()Lorg/apache/qpid/proton/message/Message;
checkcast org.apache.qpid.proton.message.impl.MessageImpl
astore 4
start local 4 16: new io.vertx.proton.impl.ProtonDeliveryImpl
dup
aload 2
invokespecial io.vertx.proton.impl.ProtonDeliveryImpl.<init>:(Lorg/apache/qpid/proton/engine/Delivery;)V
astore 5
start local 5 17: aload 4
aload 3
invokevirtual org.apache.qpid.proton.message.impl.MessageImpl.decode:(Lorg/apache/qpid/proton/codec/ReadableBuffer;)V
18: goto 23
StackMap locals: io.vertx.proton.impl.ProtonReceiverImpl org.apache.qpid.proton.engine.Receiver org.apache.qpid.proton.engine.Delivery org.apache.qpid.proton.codec.ReadableBuffer org.apache.qpid.proton.message.impl.MessageImpl io.vertx.proton.impl.ProtonDeliveryImpl
StackMap stack: java.lang.Throwable
19: astore 6
start local 6 20: getstatic io.vertx.proton.impl.ProtonReceiverImpl.LOG:Lio/vertx/core/logging/Logger;
ldc "Unable to decode message, undeliverable"
aload 6
invokevirtual io.vertx.core.logging.Logger.debug:(Ljava/lang/Object;Ljava/lang/Throwable;)V
21: aload 0
aload 1
aload 5
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.handleDecodeFailure:(Lorg/apache/qpid/proton/engine/Receiver;Lio/vertx/proton/impl/ProtonDeliveryImpl;)V
22: return
end local 6 23: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.handler:Lio/vertx/proton/ProtonMessageHandler;
aload 5
aload 4
invokeinterface io.vertx.proton.ProtonMessageHandler.handle:(Lio/vertx/proton/ProtonDelivery;Lorg/apache/qpid/proton/message/Message;)V
24: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.autoAccept:Z
ifeq 26
aload 2
invokeinterface org.apache.qpid.proton.engine.Delivery.getLocalState:()Lorg/apache/qpid/proton/amqp/transport/DeliveryState;
ifnonnull 26
25: aload 5
iconst_1
invokestatic io.vertx.proton.ProtonHelper.accepted:(Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
pop
26: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
ifle 29
27: aload 0
iconst_1
iconst_0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.flow:(IZ)V
28: goto 30
29: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.processForDrainCompletion:()V
end local 5 end local 4 end local 3 30: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 31 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
3 31 1 receiver Lorg/apache/qpid/proton/engine/Receiver;
4 31 2 delivery Lorg/apache/qpid/proton/engine/Delivery;
12 30 3 data Lorg/apache/qpid/proton/codec/ReadableBuffer;
16 30 4 msg Lorg/apache/qpid/proton/message/impl/MessageImpl;
17 30 5 delImpl Lio/vertx/proton/impl/ProtonDeliveryImpl;
20 23 6 t Ljava/lang/Throwable;
Exception table:
from to target type
17 18 19 Class java.lang.Throwable
private void handleDecodeFailure(org.apache.qpid.proton.engine.Receiver, io.vertx.proton.impl.ProtonDeliveryImpl);
descriptor: (Lorg/apache/qpid/proton/engine/Receiver;Lio/vertx/proton/impl/ProtonDeliveryImpl;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new org.apache.qpid.proton.amqp.messaging.Modified
dup
invokespecial org.apache.qpid.proton.amqp.messaging.Modified.<init>:()V
astore 3
start local 3 1: aload 3
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual org.apache.qpid.proton.amqp.messaging.Modified.setDeliveryFailed:(Ljava/lang/Boolean;)V
2: aload 3
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual org.apache.qpid.proton.amqp.messaging.Modified.setUndeliverableHere:(Ljava/lang/Boolean;)V
3: aload 2
aload 3
iconst_1
invokevirtual io.vertx.proton.impl.ProtonDeliveryImpl.disposition:(Lorg/apache/qpid/proton/amqp/transport/DeliveryState;Z)Lio/vertx/proton/ProtonDelivery;
pop
4: aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.getDrain:()Z
ifne 7
5: aload 0
iconst_1
iconst_0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.flow:(IZ)V
6: goto 8
7: StackMap locals: org.apache.qpid.proton.amqp.messaging.Modified
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.processForDrainCompletion:()V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 9 1 receiver Lorg/apache/qpid/proton/engine/Receiver;
0 9 2 delImpl Lio/vertx/proton/impl/ProtonDeliveryImpl;
1 9 3 modified Lorg/apache/qpid/proton/amqp/messaging/Modified;
MethodParameters:
Name Flags
receiver
delImpl
private void handleAborted(org.apache.qpid.proton.engine.Receiver, org.apache.qpid.proton.engine.Delivery);
descriptor: (Lorg/apache/qpid/proton/engine/Receiver;Lorg/apache/qpid/proton/engine/Delivery;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
1: aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.advance:()Z
pop
2: aload 2
invokeinterface org.apache.qpid.proton.engine.Delivery.settle:()V
3: aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.getDrain:()Z
ifne 6
4: aload 0
iconst_1
iconst_0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.flow:(IZ)V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.processForDrainCompletion:()V
7: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 8 1 receiver Lorg/apache/qpid/proton/engine/Receiver;
0 8 2 delivery Lorg/apache/qpid/proton/engine/Delivery;
MethodParameters:
Name Flags
receiver
delivery
private void handlePartial(org.apache.qpid.proton.engine.Receiver, org.apache.qpid.proton.engine.Delivery);
descriptor: (Lorg/apache/qpid/proton/engine/Receiver;Lorg/apache/qpid/proton/engine/Delivery;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.sessionIncomingCapacity:J
lconst_0
lcmp
ifle 13
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.maxFrameSize:I
ifle 13
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.session:Lorg/apache/qpid/proton/engine/Session;
invokeinterface org.apache.qpid.proton.engine.Session.getIncomingBytes:()I
i2l
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.windowFullThreshhold:J
lcmp
iflt 13
1: aload 2
invokeinterface org.apache.qpid.proton.engine.Delivery.available:()I
ifle 13
2: aload 1
invokeinterface org.apache.qpid.proton.engine.Receiver.recv:()Lorg/apache/qpid/proton/codec/ReadableBuffer;
astore 3
start local 3 3: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
ifnonnull 6
aload 3
instanceof org.apache.qpid.proton.codec.CompositeReadableBuffer
ifeq 6
4: aload 0
aload 3
checkcast org.apache.qpid.proton.codec.CompositeReadableBuffer
putfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
5: goto 13
6: StackMap locals: org.apache.qpid.proton.codec.ReadableBuffer
StackMap stack:
aload 3
invokeinterface org.apache.qpid.proton.codec.ReadableBuffer.remaining:()I
istore 4
start local 4 7: iload 4
ifle 13
8: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
ifnonnull 10
9: aload 0
new org.apache.qpid.proton.codec.CompositeReadableBuffer
dup
invokespecial org.apache.qpid.proton.codec.CompositeReadableBuffer.<init>:()V
putfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
10: StackMap locals: int
StackMap stack:
iload 4
newarray 8
astore 5
start local 5 11: aload 3
aload 5
invokeinterface org.apache.qpid.proton.codec.ReadableBuffer.get:([B)Lorg/apache/qpid/proton/codec/ReadableBuffer;
pop
12: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
aload 5
invokevirtual org.apache.qpid.proton.codec.CompositeReadableBuffer.append:([B)Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
pop
end local 5 end local 4 end local 3 13: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 14 1 receiver Lorg/apache/qpid/proton/engine/Receiver;
0 14 2 delivery Lorg/apache/qpid/proton/engine/Delivery;
3 13 3 buff Lorg/apache/qpid/proton/codec/ReadableBuffer;
7 13 4 remaining I
11 13 5 chunk [B
MethodParameters:
Name Flags
receiver final
delivery final
private org.apache.qpid.proton.codec.ReadableBuffer completePartial(org.apache.qpid.proton.codec.ReadableBuffer);
descriptor: (Lorg/apache/qpid/proton/codec/ReadableBuffer;)Lorg/apache/qpid/proton/codec/ReadableBuffer;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface org.apache.qpid.proton.codec.ReadableBuffer.remaining:()I
istore 2
start local 2 1: iload 2
ifle 5
2: iload 2
newarray 8
astore 3
start local 3 3: aload 1
aload 3
invokeinterface org.apache.qpid.proton.codec.ReadableBuffer.get:([B)Lorg/apache/qpid/proton/codec/ReadableBuffer;
pop
4: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
aload 3
invokevirtual org.apache.qpid.proton.codec.CompositeReadableBuffer.append:([B)Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
pop
end local 3 5: StackMap locals: int
StackMap stack:
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
astore 3
start local 3 6: aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonReceiverImpl.splitContent:Lorg/apache/qpid/proton/codec/CompositeReadableBuffer;
7: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 8 1 finalContent Lorg/apache/qpid/proton/codec/ReadableBuffer;
1 8 2 pending I
3 5 3 chunk [B
6 8 3 data Lorg/apache/qpid/proton/codec/ReadableBuffer;
MethodParameters:
Name Flags
finalContent final
public boolean isAutoAccept();
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.ProtonReceiverImpl.autoAccept:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
public io.vertx.proton.ProtonReceiver setAutoAccept(boolean);
descriptor: (Z)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
iload 1
putfield io.vertx.proton.impl.ProtonReceiverImpl.autoAccept: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/ProtonReceiverImpl;
0 2 1 autoAccept Z
MethodParameters:
Name Flags
autoAccept
public io.vertx.proton.ProtonReceiver setPrefetch(int);
descriptor: (I)Lio/vertx/proton/ProtonReceiver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: iload 1
ifge 2
1: new java.lang.IllegalArgumentException
dup
ldc "Value must not be negative"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
iload 1
putfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
3: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 4 1 messages I
MethodParameters:
Name Flags
messages
public int getPrefetch();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
public io.vertx.proton.ProtonReceiver open();
descriptor: ()Lio/vertx/proton/ProtonReceiver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.vertx.proton.impl.ProtonLinkImpl.open:()Lio/vertx/proton/ProtonLink;
pop
1: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
ifle 3
2: aload 0
aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.prefetch:I
iconst_0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.flow:(IZ)V
3: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
void handleLinkFlow();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.processForDrainCompletion:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
private void processForDrainCompletion();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=1
start local 0 0: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.drainCompleteHandler:Lio/vertx/core/Handler;
astore 1
start local 1 1: aload 1
ifnull 13
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getCredit:()I
ifgt 13
aload 0
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.getQueued:()I
ifgt 13
2: iconst_0
istore 2
start local 2 3: aload 0
getfield io.vertx.proton.impl.ProtonReceiverImpl.drainTimeoutTaskId:Ljava/lang/Long;
astore 3
start local 3 4: aload 3
ifnull 8
5: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
invokeinterface io.vertx.core.Context.owner:()Lio/vertx/core/Vertx;
astore 4
start local 4 6: aload 4
aload 3
invokevirtual java.lang.Long.longValue:()J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
istore 2
end local 4 7: goto 9
8: StackMap locals: io.vertx.core.Handler int java.lang.Long
StackMap stack:
iconst_1
istore 2
9: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonReceiverImpl.drainTimeoutTaskId:Ljava/lang/Long;
10: aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonReceiverImpl.drainCompleteHandler:Lio/vertx/core/Handler;
11: iload 2
ifeq 13
12: aload 1
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 3 end local 2 13: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
1 14 1 h Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
3 13 2 timeoutTaskCleared Z
4 13 3 timerId Ljava/lang/Long;
6 7 4 vertx Lio/vertx/core/Vertx;
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 int drained();
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.drained:()I
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
invokevirtual io.vertx.proton.impl.ProtonReceiverImpl.open:()Lio/vertx/proton/ProtonReceiver;
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.ProtonReceiverImpl.self:()Lio/vertx/proton/impl/ProtonReceiverImpl;
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
private void lambda$0(io.vertx.core.Handler, java.lang.Long);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonReceiverImpl.drainTimeoutTaskId:Ljava/lang/Long;
1: aload 0
aconst_null
putfield io.vertx.proton.impl.ProtonReceiverImpl.drainCompleteHandler:Lio/vertx/core/Handler;
2: aload 1
ldc "Drain attempt timed out"
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
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/proton/impl/ProtonReceiverImpl;
0 4 2 x Ljava/lang/Long;
}
Signature: Lio/vertx/proton/impl/ProtonLinkImpl<Lio/vertx/proton/ProtonReceiver;>;Lio/vertx/proton/ProtonReceiver;
SourceFile: "ProtonReceiverImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles