public interface io.vertx.proton.ProtonHelper
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: io.vertx.proton.ProtonHelper
super_class: java.lang.Object
{
public static org.apache.qpid.proton.message.Message message();
descriptor: ()Lorg/apache/qpid/proton/message/Message;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic org.apache.qpid.proton.Proton.message:()Lorg/apache/qpid/proton/message/Message;
areturn
LocalVariableTable:
Start End Slot Name Signature
public static org.apache.qpid.proton.message.Message message(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/qpid/proton/message/Message;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: invokestatic io.vertx.proton.ProtonHelper.message:()Lorg/apache/qpid/proton/message/Message;
astore 1
start local 1 1: aload 1
new org.apache.qpid.proton.amqp.messaging.AmqpValue
dup
aload 0
invokespecial org.apache.qpid.proton.amqp.messaging.AmqpValue.<init>:(Ljava/lang/Object;)V
invokeinterface org.apache.qpid.proton.message.Message.setBody:(Lorg/apache/qpid/proton/amqp/messaging/Section;)V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 body Ljava/lang/String;
1 3 1 value Lorg/apache/qpid/proton/message/Message;
MethodParameters:
Name Flags
body
public static org.apache.qpid.proton.message.Message message(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/qpid/proton/message/Message;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokestatic io.vertx.proton.ProtonHelper.message:(Ljava/lang/String;)Lorg/apache/qpid/proton/message/Message;
astore 2
start local 2 1: aload 2
aload 0
invokeinterface org.apache.qpid.proton.message.Message.setAddress:(Ljava/lang/String;)V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 address Ljava/lang/String;
0 3 1 body Ljava/lang/String;
1 3 2 value Lorg/apache/qpid/proton/message/Message;
MethodParameters:
Name Flags
address
body
public static org.apache.qpid.proton.amqp.transport.ErrorCondition condition(org.apache.qpid.proton.amqp.Symbol, java.lang.String);
descriptor: (Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.qpid.proton.amqp.transport.ErrorCondition
dup
aload 0
aload 1
invokespecial org.apache.qpid.proton.amqp.transport.ErrorCondition.<init>:(Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/String;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 condition Lorg/apache/qpid/proton/amqp/Symbol;
0 1 1 description Ljava/lang/String;
MethodParameters:
Name Flags
condition
description
public static org.apache.qpid.proton.amqp.transport.ErrorCondition condition(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic org.apache.qpid.proton.amqp.Symbol.valueOf:(Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/Symbol;
aload 1
invokestatic io.vertx.proton.ProtonHelper.condition:(Lorg/apache/qpid/proton/amqp/Symbol;Ljava/lang/String;)Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 condition Ljava/lang/String;
0 1 1 description Ljava/lang/String;
MethodParameters:
Name Flags
condition
description
public static byte[] tag(java.lang.String);
descriptor: (Ljava/lang/String;)[B
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokevirtual java.lang.String.getBytes:(Ljava/nio/charset/Charset;)[B
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 tag Ljava/lang/String;
MethodParameters:
Name Flags
tag
public static io.vertx.proton.ProtonDelivery accepted(io.vertx.proton.ProtonDelivery, boolean);
descriptor: (Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic org.apache.qpid.proton.amqp.messaging.Accepted.getInstance:()Lorg/apache/qpid/proton/amqp/messaging/Accepted;
iload 1
invokeinterface io.vertx.proton.ProtonDelivery.disposition:(Lorg/apache/qpid/proton/amqp/transport/DeliveryState;Z)Lio/vertx/proton/ProtonDelivery;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 delivery Lio/vertx/proton/ProtonDelivery;
0 2 1 settle Z
MethodParameters:
Name Flags
delivery
settle
public static io.vertx.proton.ProtonDelivery rejected(io.vertx.proton.ProtonDelivery, boolean);
descriptor: (Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.qpid.proton.amqp.messaging.Rejected
dup
invokespecial org.apache.qpid.proton.amqp.messaging.Rejected.<init>:()V
iload 1
invokeinterface io.vertx.proton.ProtonDelivery.disposition:(Lorg/apache/qpid/proton/amqp/transport/DeliveryState;Z)Lio/vertx/proton/ProtonDelivery;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 delivery Lio/vertx/proton/ProtonDelivery;
0 2 1 settle Z
MethodParameters:
Name Flags
delivery
settle
public static io.vertx.proton.ProtonDelivery released(io.vertx.proton.ProtonDelivery, boolean);
descriptor: (Lio/vertx/proton/ProtonDelivery;Z)Lio/vertx/proton/ProtonDelivery;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokestatic org.apache.qpid.proton.amqp.messaging.Released.getInstance:()Lorg/apache/qpid/proton/amqp/messaging/Released;
iload 1
invokeinterface io.vertx.proton.ProtonDelivery.disposition:(Lorg/apache/qpid/proton/amqp/transport/DeliveryState;Z)Lio/vertx/proton/ProtonDelivery;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 delivery Lio/vertx/proton/ProtonDelivery;
0 2 1 settle Z
MethodParameters:
Name Flags
delivery
settle
public static io.vertx.proton.ProtonDelivery modified(io.vertx.proton.ProtonDelivery, boolean, boolean, boolean);
descriptor: (Lio/vertx/proton/ProtonDelivery;ZZZ)Lio/vertx/proton/ProtonDelivery;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.apache.qpid.proton.amqp.messaging.Modified
dup
invokespecial org.apache.qpid.proton.amqp.messaging.Modified.<init>:()V
astore 4
start local 4 1: aload 4
iload 2
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual org.apache.qpid.proton.amqp.messaging.Modified.setDeliveryFailed:(Ljava/lang/Boolean;)V
2: aload 4
iload 3
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual org.apache.qpid.proton.amqp.messaging.Modified.setUndeliverableHere:(Ljava/lang/Boolean;)V
3: aload 0
aload 4
iload 1
invokeinterface io.vertx.proton.ProtonDelivery.disposition:(Lorg/apache/qpid/proton/amqp/transport/DeliveryState;Z)Lio/vertx/proton/ProtonDelivery;
pop
4: aload 0
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 delivery Lio/vertx/proton/ProtonDelivery;
0 5 1 settle Z
0 5 2 deliveryFailed Z
0 5 3 undeliverableHere Z
1 5 4 modified Lorg/apache/qpid/proton/amqp/messaging/Modified;
MethodParameters:
Name Flags
delivery
settle
deliveryFailed
undeliverableHere
public static <T> io.vertx.core.AsyncResult<T> future(T, org.apache.qpid.proton.amqp.transport.ErrorCondition);
descriptor: (Ljava/lang/Object;Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/core/AsyncResult;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.qpid.proton.amqp.transport.ErrorCondition.getCondition:()Lorg/apache/qpid/proton/amqp/Symbol;
ifnull 2
1: aload 1
invokevirtual org.apache.qpid.proton.amqp.transport.ErrorCondition.toString:()Ljava/lang/String;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 value TT;
0 3 1 err Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;
Signature: <T:Ljava/lang/Object;>(TT;Lorg/apache/qpid/proton/amqp/transport/ErrorCondition;)Lio/vertx/core/AsyncResult<TT;>;
MethodParameters:
Name Flags
value
err
}
SourceFile: "ProtonHelper.java"