class io.vertx.rabbitmq.impl.Utils
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.rabbitmq.impl.Utils
super_class: java.lang.Object
{
private static final java.time.format.DateTimeFormatter dateTimeFormatter;
descriptor: Ljava/time/format/DateTimeFormatter;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic java.time.format.DateTimeFormatter.ISO_DATE_TIME:Ljava/time/format/DateTimeFormatter;
putstatic io.vertx.rabbitmq.impl.Utils.dateTimeFormatter:Ljava/time/format/DateTimeFormatter;
return
LocalVariableTable:
Start End Slot Name Signature
void <init>();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/rabbitmq/impl/Utils;
public static void populate(io.vertx.core.json.JsonObject, com.rabbitmq.client.Envelope);
descriptor: (Lio/vertx/core/json/JsonObject;Lcom/rabbitmq/client/Envelope;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 1
return
1: StackMap locals:
StackMap stack:
ldc "deliveryTag"
aload 1
invokevirtual com.rabbitmq.client.Envelope.getDeliveryTag:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aload 0
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
2: ldc "isRedeliver"
aload 1
invokevirtual com.rabbitmq.client.Envelope.isRedeliver:()Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aload 0
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
3: ldc "exchange"
aload 1
invokevirtual com.rabbitmq.client.Envelope.getExchange:()Ljava/lang/String;
aload 0
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
4: ldc "routingKey"
aload 1
invokevirtual com.rabbitmq.client.Envelope.getRoutingKey:()Ljava/lang/String;
aload 0
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 json Lio/vertx/core/json/JsonObject;
0 6 1 envelope Lcom/rabbitmq/client/Envelope;
MethodParameters:
Name Flags
json
envelope
public static io.vertx.core.json.JsonObject toJson(com.rabbitmq.client.AMQP$Queue$DeclareOk);
descriptor: (Lcom/rabbitmq/client/AMQP$Queue$DeclareOk;)Lio/vertx/core/json/JsonObject;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
ifnonnull 1
aconst_null
areturn
1: StackMap locals:
StackMap stack:
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 1
start local 1 2: ldc "queue"
aload 0
invokeinterface com.rabbitmq.client.AMQP$Queue$DeclareOk.getQueue:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
3: ldc "messageCount"
aload 0
invokeinterface com.rabbitmq.client.AMQP$Queue$DeclareOk.getMessageCount:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
4: ldc "consumerCount"
aload 0
invokeinterface com.rabbitmq.client.AMQP$Queue$DeclareOk.getConsumerCount:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
5: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 queueDeclare Lcom/rabbitmq/client/AMQP$Queue$DeclareOk;
2 6 1 json Lio/vertx/core/json/JsonObject;
MethodParameters:
Name Flags
queueDeclare
public static io.vertx.core.json.JsonObject toJson(com.rabbitmq.client.AMQP$Queue$DeleteOk);
descriptor: (Lcom/rabbitmq/client/AMQP$Queue$DeleteOk;)Lio/vertx/core/json/JsonObject;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
ifnonnull 1
aconst_null
areturn
1: StackMap locals:
StackMap stack:
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 1
start local 1 2: ldc "messageCount"
aload 0
invokeinterface com.rabbitmq.client.AMQP$Queue$DeleteOk.getMessageCount:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
3: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 queueDelete Lcom/rabbitmq/client/AMQP$Queue$DeleteOk;
2 4 1 json Lio/vertx/core/json/JsonObject;
MethodParameters:
Name Flags
queueDelete
public static io.vertx.core.json.JsonObject toJson(com.rabbitmq.client.AMQP$BasicProperties);
descriptor: (Lcom/rabbitmq/client/AMQP$BasicProperties;)Lio/vertx/core/json/JsonObject;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
ifnonnull 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 1
start local 1 3: ldc "contentType"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getContentType:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
4: ldc "contentEncoding"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getContentEncoding:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
5: ldc "headers"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getHeaders:()Ljava/util/Map;
invokestatic io.vertx.rabbitmq.impl.Utils.convertMapLongStringToString:(Ljava/util/Map;)Ljava/util/Map;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
6: ldc "deliveryMode"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getDeliveryMode:()Ljava/lang/Integer;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
7: ldc "priority"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getPriority:()Ljava/lang/Integer;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
8: ldc "correlationId"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getCorrelationId:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
9: ldc "replyTo"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getReplyTo:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
10: ldc "expiration"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getExpiration:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
11: ldc "messageId"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getMessageId:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
12: ldc "timestamp"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getTimestamp:()Ljava/util/Date;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/util/Date;Lio/vertx/core/json/JsonObject;)V
13: ldc "type"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getType:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
14: ldc "userId"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getUserId:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
15: ldc "appId"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getAppId:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
16: ldc "clusterId"
aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getClusterId:()Ljava/lang/String;
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.put:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
17: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 properties Lcom/rabbitmq/client/AMQP$BasicProperties;
3 18 1 json Lio/vertx/core/json/JsonObject;
MethodParameters:
Name Flags
properties
private static java.util.Map<java.lang.String, java.lang.Object> convertMapLongStringToString(java.util.Map<java.lang.String, java.lang.Object>);
descriptor: (Ljava/util/Map;)Ljava/util/Map;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ifnonnull 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
3: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/util/Map$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/String;
invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
io/vertx/rabbitmq/impl/Utils.lambda$1(Ljava/util/Map$Entry;)Ljava/lang/Object; (6)
(Ljava/util/Map$Entry;)Ljava/lang/Object;
4: invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 map Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
MethodParameters:
Name Flags
map
private static java.lang.Object convertLongStringToString(java.lang.Object);
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: aload 0
instanceof com.rabbitmq.client.LongString
ifeq 2
1: aload 0
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
areturn
2: StackMap locals:
StackMap stack:
aload 0
instanceof java.util.List
ifeq 9
3: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 1
start local 1 4: aload 0
checkcast java.util.List
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 7
StackMap locals: java.lang.Object java.util.List top java.util.Iterator
StackMap stack:
5: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
astore 2
start local 2 6: aload 1
aload 2
invokestatic io.vertx.rabbitmq.impl.Utils.convertLongStringToString:(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 2 7: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
8: aload 1
areturn
end local 1 9: StackMap locals: java.lang.Object
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 value Ljava/lang/Object;
4 9 1 newList Ljava/util/List<Ljava/lang/Object;>;
6 7 2 item Ljava/lang/Object;
MethodParameters:
Name Flags
value
public static com.rabbitmq.client.AMQP$BasicProperties fromJson(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Lcom/rabbitmq/client/AMQP$BasicProperties;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ifnonnull 2
1: new com.rabbitmq.client.AMQP$BasicProperties
dup
invokespecial com.rabbitmq.client.AMQP$BasicProperties.<init>:()V
areturn
2: StackMap locals:
StackMap stack:
new com.rabbitmq.client.AMQP$BasicProperties$Builder
dup
invokespecial com.rabbitmq.client.AMQP$BasicProperties$Builder.<init>:()V
3: aload 0
ldc "contentType"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.contentType:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
4: aload 0
ldc "contentEncoding"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.contentEncoding:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
5: aload 0
ldc "headers"
invokevirtual io.vertx.core.json.JsonObject.getJsonObject:(Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.rabbitmq.impl.Utils.asMap:(Lio/vertx/core/json/JsonObject;)Ljava/util/Map;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.headers:(Ljava/util/Map;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
6: aload 0
ldc "deliveryMode"
invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;)Ljava/lang/Integer;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.deliveryMode:(Ljava/lang/Integer;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
7: aload 0
ldc "priority"
invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;)Ljava/lang/Integer;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.priority:(Ljava/lang/Integer;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
8: aload 0
ldc "correlationId"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.correlationId:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
9: aload 0
ldc "replyTo"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.replyTo:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
10: aload 0
ldc "expiration"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.expiration:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
11: aload 0
ldc "messageId"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.messageId:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
12: aload 0
ldc "timestamp"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic io.vertx.rabbitmq.impl.Utils.parseDate:(Ljava/lang/String;)Ljava/util/Date;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.timestamp:(Ljava/util/Date;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
13: aload 0
ldc "type"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.type:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
14: aload 0
ldc "userId"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.userId:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
15: aload 0
ldc "appId"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.appId:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
16: aload 0
ldc "clusterId"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.clusterId:(Ljava/lang/String;)Lcom/rabbitmq/client/AMQP$BasicProperties$Builder;
invokevirtual com.rabbitmq.client.AMQP$BasicProperties$Builder.build:()Lcom/rabbitmq/client/AMQP$BasicProperties;
17: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 json Lio/vertx/core/json/JsonObject;
MethodParameters:
Name Flags
json
public static java.lang.Object parse(com.rabbitmq.client.AMQP$BasicProperties, byte[]);
descriptor: (Lcom/rabbitmq/client/AMQP$BasicProperties;[B)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 1
aconst_null
areturn
1: StackMap locals:
StackMap stack:
aload 0
ifnull 13
2: aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getContentEncoding:()Ljava/lang/String;
astore 2
start local 2 3: aload 0
invokevirtual com.rabbitmq.client.AMQP$BasicProperties.getContentType:()Ljava/lang/String;
astore 3
start local 3 4: aload 3
ifnonnull 6
5: aload 2
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.decode:(Ljava/lang/String;[B)Ljava/lang/String;
areturn
6: StackMap locals: java.lang.String java.lang.String
StackMap stack:
aload 3
dup
astore 4
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 3
-43840953: 7
817335912: 8
1178484637: 9
default: 12
}
StackMap locals: java.lang.String
StackMap stack:
7: aload 4
ldc "application/json"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 12
StackMap locals:
StackMap stack:
8: aload 4
ldc "text/plain"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 12
goto 12
StackMap locals:
StackMap stack:
9: aload 4
ldc "application/octet-stream"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
goto 12
10: StackMap locals:
StackMap stack:
new io.vertx.core.json.JsonObject
dup
aload 2
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.decode:(Ljava/lang/String;[B)Ljava/lang/String;
invokespecial io.vertx.core.json.JsonObject.<init>:(Ljava/lang/String;)V
areturn
11: StackMap locals:
StackMap stack:
aload 1
areturn
12: StackMap locals:
StackMap stack:
aload 2
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.decode:(Ljava/lang/String;[B)Ljava/lang/String;
areturn
end local 3 end local 2 13: StackMap locals:
StackMap stack:
aconst_null
aload 1
invokestatic io.vertx.rabbitmq.impl.Utils.decode:(Ljava/lang/String;[B)Ljava/lang/String;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 properties Lcom/rabbitmq/client/AMQP$BasicProperties;
0 14 1 bytes [B
3 13 2 encoding Ljava/lang/String;
4 13 3 ct Ljava/lang/String;
Exceptions:
throws java.io.UnsupportedEncodingException
MethodParameters:
Name Flags
properties
bytes
public static java.lang.String decode(java.lang.String, byte[]);
descriptor: (Ljava/lang/String;[B)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ifnonnull 2
1: new java.lang.String
dup
aload 1
ldc "UTF-8"
invokespecial java.lang.String.<init>:([BLjava/lang/String;)V
areturn
2: StackMap locals:
StackMap stack:
new java.lang.String
dup
aload 1
aload 0
invokespecial java.lang.String.<init>:([BLjava/lang/String;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 encoding Ljava/lang/String;
0 3 1 bytes [B
Exceptions:
throws java.io.UnsupportedEncodingException
MethodParameters:
Name Flags
encoding
bytes
public static byte[] encode(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)[B
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ifnonnull 2
1: aload 1
invokevirtual java.lang.String.getBytes:()[B
areturn
2: StackMap locals:
StackMap stack:
aload 1
aload 0
invokevirtual java.lang.String.getBytes:(Ljava/lang/String;)[B
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 encoding Ljava/lang/String;
0 3 1 string Ljava/lang/String;
Exceptions:
throws java.io.UnsupportedEncodingException
MethodParameters:
Name Flags
encoding
string
public static void put(java.lang.String, java.lang.Object, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/json/JsonObject;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnull 2
1: aload 2
aload 0
aload 1
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
2: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 field Ljava/lang/String;
0 3 1 value Ljava/lang/Object;
0 3 2 json Lio/vertx/core/json/JsonObject;
MethodParameters:
Name Flags
field
value
json
public static void put(java.lang.String, java.util.Date, io.vertx.core.json.JsonObject);
descriptor: (Ljava/lang/String;Ljava/util/Date;Lio/vertx/core/json/JsonObject;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnonnull 1
return
1: StackMap locals:
StackMap stack:
aload 1
invokevirtual java.util.Date.toInstant:()Ljava/time/Instant;
ldc "UTC"
invokestatic java.time.ZoneId.of:(Ljava/lang/String;)Ljava/time/ZoneId;
invokestatic java.time.OffsetDateTime.ofInstant:(Ljava/time/Instant;Ljava/time/ZoneId;)Ljava/time/OffsetDateTime;
astore 3
start local 3 2: aload 3
getstatic io.vertx.rabbitmq.impl.Utils.dateTimeFormatter:Ljava/time/format/DateTimeFormatter;
invokevirtual java.time.OffsetDateTime.format:(Ljava/time/format/DateTimeFormatter;)Ljava/lang/String;
astore 4
start local 4 3: aload 2
aload 0
aload 4
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
pop
4: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 field Ljava/lang/String;
0 5 1 value Ljava/util/Date;
0 5 2 json Lio/vertx/core/json/JsonObject;
2 5 3 date Ljava/time/OffsetDateTime;
3 5 4 format Ljava/lang/String;
MethodParameters:
Name Flags
field
value
json
public static java.util.Date parseDate(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Date;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
ifnonnull 1
aconst_null
areturn
1: StackMap locals:
StackMap stack:
aload 0
getstatic io.vertx.rabbitmq.impl.Utils.dateTimeFormatter:Ljava/time/format/DateTimeFormatter;
invokestatic java.time.OffsetDateTime.parse:(Ljava/lang/CharSequence;Ljava/time/format/DateTimeFormatter;)Ljava/time/OffsetDateTime;
astore 1
start local 1 2: aload 1
invokevirtual java.time.OffsetDateTime.toInstant:()Ljava/time/Instant;
invokestatic java.util.Date.from:(Ljava/time/Instant;)Ljava/util/Date;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 date Ljava/lang/String;
2 3 1 odt Ljava/time/OffsetDateTime;
MethodParameters:
Name Flags
date
public static java.util.Map<java.lang.String, java.lang.Object> asMap(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)Ljava/util/Map;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
ifnonnull 1
aconst_null
areturn
1: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.json.JsonObject.getMap:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 json Lio/vertx/core/json/JsonObject;
Signature: (Lio/vertx/core/json/JsonObject;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
MethodParameters:
Name Flags
json
private static java.lang.Object lambda$1(java.util.Map$Entry);
descriptor: (Ljava/util/Map$Entry;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokestatic io.vertx.rabbitmq.impl.Utils.convertLongStringToString:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 e Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Object;>;
}
SourceFile: "Utils.java"
InnerClasses:
public BasicProperties = com.rabbitmq.client.AMQP$BasicProperties of com.rabbitmq.client.AMQP
public final Builder = com.rabbitmq.client.AMQP$BasicProperties$Builder of com.rabbitmq.client.AMQP$BasicProperties
public Queue = com.rabbitmq.client.AMQP$Queue of com.rabbitmq.client.AMQP
public abstract DeclareOk = com.rabbitmq.client.AMQP$Queue$DeclareOk of com.rabbitmq.client.AMQP$Queue
public abstract DeleteOk = com.rabbitmq.client.AMQP$Queue$DeleteOk of com.rabbitmq.client.AMQP$Queue
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map