public class io.vertx.amqpbridge.impl.AmqpMessageImpl implements io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.amqpbridge.impl.AmqpMessageImpl
super_class: java.lang.Object
{
private final io.vertx.core.json.JsonObject body;
descriptor: Lio/vertx/core/json/JsonObject;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.amqpbridge.impl.AmqpBridgeImpl bridge;
descriptor: Lio/vertx/amqpbridge/impl/AmqpBridgeImpl;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.qpid.proton.message.Message protonMessage;
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 final java.lang.String amqpAddress;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String amqpReplyAddress;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(io.vertx.core.json.JsonObject, io.vertx.amqpbridge.impl.AmqpBridgeImpl, org.apache.qpid.proton.message.Message, io.vertx.proton.ProtonDelivery, java.lang.String, java.lang.String);
descriptor: (Lio/vertx/core/json/JsonObject;Lio/vertx/amqpbridge/impl/AmqpBridgeImpl;Lorg/apache/qpid/proton/message/Message;Lio/vertx/proton/ProtonDelivery;Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.amqpbridge.impl.AmqpMessageImpl.body:Lio/vertx/core/json/JsonObject;
2: aload 0
aload 2
putfield io.vertx.amqpbridge.impl.AmqpMessageImpl.bridge:Lio/vertx/amqpbridge/impl/AmqpBridgeImpl;
3: aload 0
aload 3
putfield io.vertx.amqpbridge.impl.AmqpMessageImpl.protonMessage:Lorg/apache/qpid/proton/message/Message;
4: aload 0
aload 4
putfield io.vertx.amqpbridge.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
5: aload 0
aload 5
putfield io.vertx.amqpbridge.impl.AmqpMessageImpl.amqpAddress:Ljava/lang/String;
6: aload 0
aload 6
putfield io.vertx.amqpbridge.impl.AmqpMessageImpl.amqpReplyAddress:Ljava/lang/String;
7: return
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 8 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
0 8 1 body Lio/vertx/core/json/JsonObject;
0 8 2 bridge Lio/vertx/amqpbridge/impl/AmqpBridgeImpl;
0 8 3 protonMessage Lorg/apache/qpid/proton/message/Message;
0 8 4 delivery Lio/vertx/proton/ProtonDelivery;
0 8 5 amqpAddress Ljava/lang/String;
0 8 6 amqpReplyAddress Ljava/lang/String;
MethodParameters:
Name Flags
body
bridge
protonMessage
delivery
amqpAddress
amqpReplyAddress
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.amqpbridge.impl.AmqpMessageImpl.amqpAddress:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
public io.vertx.core.MultiMap ();
descriptor: ()Lio/vertx/core/MultiMap;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.UnsupportedOperationException
dup
1: ldc "Use the AMQP application-properties section via the JsonObject payload body, headers method is not supported"
2: invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
public io.vertx.core.json.JsonObject body();
descriptor: ()Lio/vertx/core/json/JsonObject;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqpbridge.impl.AmqpMessageImpl.body:Lio/vertx/core/json/JsonObject;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
public java.lang.String replyAddress();
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.amqpbridge.impl.AmqpMessageImpl.amqpReplyAddress:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
public boolean isSend();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
private <R> void doReply(, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.eventbus.Message<R>>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
instanceof io.vertx.core.json.JsonObject
ifne 2
1: new java.lang.IllegalArgumentException
dup
ldc "The reply body must be an instance of JsonObject"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.amqpbridge.impl.AmqpMessageImpl.bridge:Lio/vertx/amqpbridge/impl/AmqpBridgeImpl;
aload 0
getfield io.vertx.amqpbridge.impl.AmqpMessageImpl.protonMessage:Lorg/apache/qpid/proton/message/Message;
aload 1
checkcast io.vertx.core.json.JsonObject
aload 2
invokevirtual io.vertx.amqpbridge.impl.AmqpBridgeImpl.sendReply:(Lorg/apache/qpid/proton/message/Message;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Handler;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
0 4 1 replyMessageBody Ljava/lang/Object;
0 4 2 replyHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<TR;>;>;>;
Signature: <R:Ljava/lang/Object;>(Ljava/lang/Object;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<TR;>;>;>;)V
MethodParameters:
Name Flags
replyMessageBody
replyHandler
public void reply(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
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.amqpbridge.impl.AmqpMessageImpl.doReply:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
0 2 1 replyMessageBody Ljava/lang/Object;
MethodParameters:
Name Flags
replyMessageBody
public <R> void reply(, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.eventbus.Message<R>>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.amqpbridge.impl.AmqpMessageImpl.doReply:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
0 2 1 replyMessageBody Ljava/lang/Object;
0 2 2 replyHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<TR;>;>;>;
Signature: <R:Ljava/lang/Object;>(Ljava/lang/Object;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<TR;>;>;>;)V
MethodParameters:
Name Flags
replyMessageBody
replyHandler
public void reply(java.lang.Object, io.vertx.core.eventbus.DeliveryOptions);
descriptor: (Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new java.lang.UnsupportedOperationException
dup
ldc "DeliveryOptions are not supported"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
0 1 1 messageBody Ljava/lang/Object;
0 1 2 options Lio/vertx/core/eventbus/DeliveryOptions;
MethodParameters:
Name Flags
messageBody
options
public <R> void reply(, io.vertx.core.eventbus.DeliveryOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.eventbus.Message<R>>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.lang.UnsupportedOperationException
dup
ldc "DeliveryOptions are not supported"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
0 1 1 messageBody Ljava/lang/Object;
0 1 2 options Lio/vertx/core/eventbus/DeliveryOptions;
0 1 3 replyHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<TR;>;>;>;
Signature: <R:Ljava/lang/Object;>(Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<TR;>;>;>;)V
MethodParameters:
Name Flags
messageBody
options
replyHandler
public void fail(int, java.lang.String);
descriptor: (ILjava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new java.lang.UnsupportedOperationException
dup
ldc "Implicit failure responses are not supported, send a message explicitly."
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
0 1 1 failureCode I
0 1 2 message Ljava/lang/String;
MethodParameters:
Name Flags
failureCode
message
void accept();
descriptor: ()V
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.amqpbridge.impl.AmqpMessageImpl.delivery:Lio/vertx/proton/ProtonDelivery;
iconst_1
invokestatic io.vertx.proton.ProtonHelper.accepted:(Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/amqpbridge/impl/AmqpMessageImpl;
public java.lang.Object body();
descriptor: ()Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.amqpbridge.impl.AmqpMessageImpl.body:()Lio/vertx/core/json/JsonObject;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Ljava/lang/Object;Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;
SourceFile: "AmqpMessageImpl.java"