public class io.vertx.amqp.impl.AmqpMessageImpl implements io.vertx.amqp.AmqpMessage
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.amqp.impl.AmqpMessageImpl
super_class: java.lang.Object
{
private final org.apache.qpid.proton.message.Message message;
descriptor: Lorg/apache/qpid/proton/message/Message;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.proton.ProtonDelivery delivery;
descriptor: Lio/vertx/proton/ProtonDelivery;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.amqp.impl.AmqpConnectionImpl connection;
descriptor: Lio/vertx/amqp/impl/AmqpConnectionImpl;
flags: (0x0002) ACC_PRIVATE
public void <init>(org.apache.qpid.proton.message.Message, io.vertx.proton.ProtonDelivery, io.vertx.amqp.impl.AmqpConnectionImpl);
descriptor: (Lorg/apache/qpid/proton/message/Message;Lio/vertx/proton/ProtonDelivery;Lio/vertx/amqp/impl/AmqpConnectionImpl;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
2: aload 0
aload 2
putfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
3: aload 0
aload 3
putfield io.vertx.amqp.impl.AmqpMessageImpl.connection:Lio/vertx/amqp/impl/AmqpConnectionImpl;
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
0 5 1 message Lorg/apache/qpid/proton/message/Message;
0 5 2 delivery Lio/vertx/proton/ProtonDelivery;
0 5 3 connection Lio/vertx/amqp/impl/AmqpConnectionImpl;
MethodParameters:
Name Flags
message
delivery
connection
public void <init>(org.apache.qpid.proton.message.Message);
descriptor: (Lorg/apache/qpid/proton/message/Message;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
2: aload 0
aconst_null
putfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
0 4 1 message Lorg/apache/qpid/proton/message/Message;
MethodParameters:
Name Flags
message
public boolean isDurable();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.isDurable:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public boolean isFirstAcquirer();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.isFirstAcquirer:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public int priority();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getPriority:()S
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String id();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getMessageId:()Ljava/lang/Object;
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
areturn
3: StackMap locals: java.lang.Object
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 4 1 id Ljava/lang/Object;
public java.lang.String address();
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.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getAddress:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String replyTo();
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.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getReplyTo:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String correlationId();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getCorrelationId:()Ljava/lang/Object;
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
areturn
3: StackMap locals: java.lang.Object
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 4 1 id Ljava/lang/Object;
public boolean isBodyNull();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getBody:()Lorg/apache/qpid/proton/amqp/messaging/Section;
ifnull 1
aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
ifnull 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
private java.lang.Object getAmqpValue();
descriptor: ()Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getBody:()Lorg/apache/qpid/proton/amqp/messaging/Section;
invokeinterface org.apache.qpid.proton.amqp.messaging.Section.getType:()Lorg/apache/qpid/proton/amqp/messaging/Section$SectionType;
getstatic org.apache.qpid.proton.amqp.messaging.Section$SectionType.AmqpValue:Lorg/apache/qpid/proton/amqp/messaging/Section$SectionType;
if_acmpeq 2
1: new java.lang.IllegalStateException
dup
ldc "The body is not an AMQP Value"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getBody:()Lorg/apache/qpid/proton/amqp/messaging/Section;
checkcast org.apache.qpid.proton.amqp.messaging.AmqpValue
invokevirtual org.apache.qpid.proton.amqp.messaging.AmqpValue.getValue:()Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public boolean bodyAsBoolean();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Boolean
invokevirtual java.lang.Boolean.booleanValue:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public byte bodyAsByte();
descriptor: ()B
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Byte
invokevirtual java.lang.Byte.byteValue:()B
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public short bodyAsShort();
descriptor: ()S
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Short
invokevirtual java.lang.Short.shortValue:()S
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public int bodyAsInteger();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public long bodyAsLong();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Long
invokevirtual java.lang.Long.longValue:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public float bodyAsFloat();
descriptor: ()F
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Float
invokevirtual java.lang.Float.floatValue:()F
freturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public double bodyAsDouble();
descriptor: ()D
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Double
invokevirtual java.lang.Double.doubleValue:()D
dreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public char bodyAsChar();
descriptor: ()C
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.Character
invokevirtual java.lang.Character.charValue:()C
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.time.Instant bodyAsTimestamp();
descriptor: ()Ljava/time/Instant;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
astore 1
start local 1 1: aload 1
instanceof java.util.Date
ifne 3
2: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Expecting a Date object, got a "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: java.lang.Object
StackMap stack:
aload 1
checkcast java.util.Date
invokevirtual java.util.Date.toInstant:()Ljava/time/Instant;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 4 1 value Ljava/lang/Object;
public java.util.UUID bodyAsUUID();
descriptor: ()Ljava/util/UUID;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.util.UUID
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public io.vertx.core.buffer.Buffer bodyAsBinary();
descriptor: ()Lio/vertx/core/buffer/Buffer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getBody:()Lorg/apache/qpid/proton/amqp/messaging/Section;
astore 1
start local 1 1: aload 1
invokeinterface org.apache.qpid.proton.amqp.messaging.Section.getType:()Lorg/apache/qpid/proton/amqp/messaging/Section$SectionType;
getstatic org.apache.qpid.proton.amqp.messaging.Section$SectionType.Data:Lorg/apache/qpid/proton/amqp/messaging/Section$SectionType;
if_acmpeq 3
2: new java.lang.IllegalStateException
dup
ldc "The body is not of type 'data'"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: org.apache.qpid.proton.amqp.messaging.Section
StackMap stack:
aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getBody:()Lorg/apache/qpid/proton/amqp/messaging/Section;
checkcast org.apache.qpid.proton.amqp.messaging.Data
invokevirtual org.apache.qpid.proton.amqp.messaging.Data.getValue:()Lorg/apache/qpid/proton/amqp/Binary;
invokevirtual org.apache.qpid.proton.amqp.Binary.getArray:()[B
astore 2
start local 2 4: aload 2
invokestatic io.vertx.core.buffer.Buffer.buffer:([B)Lio/vertx/core/buffer/Buffer;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 5 1 body Lorg/apache/qpid/proton/amqp/messaging/Section;
4 5 2 bytes [B
public java.lang.String bodyAsString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
checkcast java.lang.String
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String bodyAsSymbol();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
astore 1
start local 1 1: aload 1
instanceof org.apache.qpid.proton.amqp.Symbol
ifeq 3
2: aload 1
checkcast org.apache.qpid.proton.amqp.Symbol
invokevirtual org.apache.qpid.proton.amqp.Symbol.toString:()Ljava/lang/String;
areturn
3: StackMap locals: java.lang.Object
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Expected a Symbol, got a "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 4 1 value Ljava/lang/Object;
public <T> java.util.List<T> bodyAsList();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getBody:()Lorg/apache/qpid/proton/amqp/messaging/Section;
astore 1
start local 1 1: aload 1
invokeinterface org.apache.qpid.proton.amqp.messaging.Section.getType:()Lorg/apache/qpid/proton/amqp/messaging/Section$SectionType;
getstatic org.apache.qpid.proton.amqp.messaging.Section$SectionType.AmqpSequence:Lorg/apache/qpid/proton/amqp/messaging/Section$SectionType;
if_acmpne 3
2: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getBody:()Lorg/apache/qpid/proton/amqp/messaging/Section;
checkcast org.apache.qpid.proton.amqp.messaging.AmqpSequence
invokevirtual org.apache.qpid.proton.amqp.messaging.AmqpSequence.getValue:()Ljava/util/List;
areturn
3: StackMap locals: org.apache.qpid.proton.amqp.messaging.Section
StackMap stack:
aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
astore 2
start local 2 4: aload 2
instanceof java.util.List
ifeq 6
5: aload 2
checkcast java.util.List
areturn
6: StackMap locals: java.lang.Object
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "Cannot extract a list from the message body"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 7 1 body Lorg/apache/qpid/proton/amqp/messaging/Section;
4 7 2 value Ljava/lang/Object;
Signature: <T:Ljava/lang/Object;>()Ljava/util/List<TT;>;
public <K, V> java.util.Map<K, V> bodyAsMap();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.getAmqpValue:()Ljava/lang/Object;
astore 1
start local 1 1: aload 1
instanceof java.util.Map
ifeq 3
2: aload 1
checkcast java.util.Map
areturn
3: StackMap locals: java.lang.Object
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "Cannot extract a map from the message body"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 4 1 value Ljava/lang/Object;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>()Ljava/util/Map<TK;TV;>;
public io.vertx.core.json.JsonObject bodyAsJsonObject();
descriptor: ()Lio/vertx/core/json/JsonObject;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.bodyAsBinary:()Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.toJsonObject:()Lio/vertx/core/json/JsonObject;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public io.vertx.core.json.JsonArray bodyAsJsonArray();
descriptor: ()Lio/vertx/core/json/JsonArray;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.amqp.impl.AmqpMessageImpl.bodyAsBinary:()Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.toJsonArray:()Lio/vertx/core/json/JsonArray;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String subject();
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.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getSubject:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String contentType();
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.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getContentType:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String contentEncoding();
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.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getContentEncoding:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public long expiryTime();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getExpiryTime:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public long creationTime();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getCreationTime:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public long ttl();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getTtl:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public int deliveryCount();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getDeliveryCount:()J
l2i
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String groupId();
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.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getGroupId:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public java.lang.String replyToGroupId();
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.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getReplyToGroupId:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public long groupSequence();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getGroupSequence:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public io.vertx.core.json.JsonObject applicationProperties();
descriptor: ()Lio/vertx/core/json/JsonObject;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
invokeinterface org.apache.qpid.proton.message.Message.getApplicationProperties:()Lorg/apache/qpid/proton/amqp/messaging/ApplicationProperties;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: aconst_null
areturn
3: StackMap locals: org.apache.qpid.proton.amqp.messaging.ApplicationProperties
StackMap stack:
aload 1
invokevirtual org.apache.qpid.proton.amqp.messaging.ApplicationProperties.getValue:()Ljava/util/Map;
invokestatic io.vertx.core.json.JsonObject.mapFrom:(Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
1 4 1 properties Lorg/apache/qpid/proton/amqp/messaging/ApplicationProperties;
public org.apache.qpid.proton.message.Message unwrap();
descriptor: ()Lorg/apache/qpid/proton/message/Message;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.message:Lorg/apache/qpid/proton/message/Message;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public io.vertx.amqp.AmqpMessage accepted();
descriptor: ()Lio/vertx/amqp/AmqpMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
ifnull 3
1: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.connection:Lio/vertx/amqp/impl/AmqpConnectionImpl;
aload 0
invokedynamic handle(Lio/vertx/amqp/impl/AmqpMessageImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/amqp/impl/AmqpMessageImpl.lambda$0(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
2: goto 4
3: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "The message is not a received message"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public io.vertx.amqp.AmqpMessage rejected();
descriptor: ()Lio/vertx/amqp/AmqpMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
ifnull 3
1: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.connection:Lio/vertx/amqp/impl/AmqpConnectionImpl;
aload 0
invokedynamic handle(Lio/vertx/amqp/impl/AmqpMessageImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/amqp/impl/AmqpMessageImpl.lambda$1(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
2: goto 4
3: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "The message is not a received message"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public io.vertx.amqp.AmqpMessage released();
descriptor: ()Lio/vertx/amqp/AmqpMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
ifnull 3
1: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.connection:Lio/vertx/amqp/impl/AmqpConnectionImpl;
aload 0
invokedynamic handle(Lio/vertx/amqp/impl/AmqpMessageImpl;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/amqp/impl/AmqpMessageImpl.lambda$2(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
2: goto 4
3: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "The message is not a received message"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
public io.vertx.amqp.AmqpMessage modified(boolean, boolean);
descriptor: (ZZ)Lio/vertx/amqp/AmqpMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
ifnull 3
1: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.connection:Lio/vertx/amqp/impl/AmqpConnectionImpl;
aload 0
iload 1
iload 2
invokedynamic handle(Lio/vertx/amqp/impl/AmqpMessageImpl;ZZ)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/amqp/impl/AmqpMessageImpl.lambda$3(ZZLjava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokevirtual io.vertx.amqp.impl.AmqpConnectionImpl.runWithTrampoline:(Lio/vertx/core/Handler;)V
2: goto 4
3: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "The message is not a received message"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
0 5 1 deliveryFailed Z
0 5 2 undeliverableHere Z
MethodParameters:
Name Flags
deliveryFailed
undeliverableHere
private void lambda$0(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
iconst_1
invokestatic io.vertx.proton.ProtonHelper.accepted:(Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
0 1 1 v Ljava/lang/Void;
private void lambda$1(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
iconst_1
invokestatic io.vertx.proton.ProtonHelper.rejected:(Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
0 1 1 v Ljava/lang/Void;
private void lambda$2(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
iconst_1
invokestatic io.vertx.proton.ProtonHelper.released:(Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
0 1 1 v Ljava/lang/Void;
private void lambda$3(boolean, boolean, java.lang.Void);
descriptor: (ZZLjava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 3 0: aload 0
getfield io.vertx.amqp.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
iconst_1
iload 1
iload 2
invokestatic io.vertx.proton.ProtonHelper.modified:(Lio/vertx/proton/ProtonDelivery;ZZZ)Lio/vertx/proton/ProtonDelivery;
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqp/impl/AmqpMessageImpl;
0 1 3 v Ljava/lang/Void;
}
SourceFile: "AmqpMessageImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public final SectionType = org.apache.qpid.proton.amqp.messaging.Section$SectionType of org.apache.qpid.proton.amqp.messaging.Section