public class io.vertx.core.eventbus.impl.CodecManager
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.eventbus.impl.CodecManager
super_class: java.lang.Object
{
public static final io.vertx.core.eventbus.MessageCodec<java.lang.String, java.lang.String> PING_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/String;Ljava/lang/String;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.String, java.lang.String> NULL_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/String;Ljava/lang/String;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.String, java.lang.String> STRING_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/String;Ljava/lang/String;>;
public static final io.vertx.core.eventbus.MessageCodec<io.vertx.core.buffer.Buffer, io.vertx.core.buffer.Buffer> BUFFER_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Lio/vertx/core/buffer/Buffer;Lio/vertx/core/buffer/Buffer;>;
public static final io.vertx.core.eventbus.MessageCodec<io.vertx.core.json.JsonObject, io.vertx.core.json.JsonObject> JSON_OBJECT_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Lio/vertx/core/json/JsonObject;Lio/vertx/core/json/JsonObject;>;
public static final io.vertx.core.eventbus.MessageCodec<io.vertx.core.json.JsonArray, io.vertx.core.json.JsonArray> JSON_ARRAY_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Lio/vertx/core/json/JsonArray;Lio/vertx/core/json/JsonArray;>;
public static final io.vertx.core.eventbus.MessageCodec<byte[], byte[]> BYTE_ARRAY_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<[B[B>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Integer, java.lang.Integer> INT_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Integer;Ljava/lang/Integer;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Long, java.lang.Long> LONG_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Long;Ljava/lang/Long;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Float, java.lang.Float> FLOAT_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Float;Ljava/lang/Float;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Double, java.lang.Double> DOUBLE_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Double;Ljava/lang/Double;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Boolean, java.lang.Boolean> BOOLEAN_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Boolean;Ljava/lang/Boolean;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Short, java.lang.Short> SHORT_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Short;Ljava/lang/Short;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Character, java.lang.Character> CHAR_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Character;Ljava/lang/Character;>;
public static final io.vertx.core.eventbus.MessageCodec<java.lang.Byte, java.lang.Byte> BYTE_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Ljava/lang/Byte;Ljava/lang/Byte;>;
public static final io.vertx.core.eventbus.MessageCodec<io.vertx.core.eventbus.ReplyException, io.vertx.core.eventbus.ReplyException> REPLY_EXCEPTION_MESSAGE_CODEC;
descriptor: Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/core/eventbus/MessageCodec<Lio/vertx/core/eventbus/ReplyException;Lio/vertx/core/eventbus/ReplyException;>;
private final io.vertx.core.eventbus.MessageCodec[] systemCodecs;
descriptor: [Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.ConcurrentMap<java.lang.String, io.vertx.core.eventbus.MessageCodec> userCodecMap;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/lang/String;Lio/vertx/core/eventbus/MessageCodec;>;
private final java.util.concurrent.ConcurrentMap<java.lang.Class, io.vertx.core.eventbus.MessageCodec> defaultCodecMap;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/lang/Class;Lio/vertx/core/eventbus/MessageCodec;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new io.vertx.core.eventbus.impl.codecs.PingMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.PingMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.PING_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
1: new io.vertx.core.eventbus.impl.codecs.NullMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.NullMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.NULL_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
2: new io.vertx.core.eventbus.impl.codecs.StringMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.StringMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.STRING_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
3: new io.vertx.core.eventbus.impl.codecs.BufferMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.BufferMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.BUFFER_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
4: new io.vertx.core.eventbus.impl.codecs.JsonObjectMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.JsonObjectMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.JSON_OBJECT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
5: new io.vertx.core.eventbus.impl.codecs.JsonArrayMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.JsonArrayMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.JSON_ARRAY_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
6: new io.vertx.core.eventbus.impl.codecs.ByteArrayMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.ByteArrayMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.BYTE_ARRAY_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
7: new io.vertx.core.eventbus.impl.codecs.IntMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.IntMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.INT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
8: new io.vertx.core.eventbus.impl.codecs.LongMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.LongMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.LONG_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
9: new io.vertx.core.eventbus.impl.codecs.FloatMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.FloatMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.FLOAT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
10: new io.vertx.core.eventbus.impl.codecs.DoubleMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.DoubleMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.DOUBLE_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
11: new io.vertx.core.eventbus.impl.codecs.BooleanMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.BooleanMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.BOOLEAN_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
12: new io.vertx.core.eventbus.impl.codecs.ShortMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.ShortMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.SHORT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
13: new io.vertx.core.eventbus.impl.codecs.CharMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.CharMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.CHAR_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
14: new io.vertx.core.eventbus.impl.codecs.ByteMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.ByteMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.BYTE_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
15: new io.vertx.core.eventbus.impl.codecs.ReplyExceptionMessageCodec
dup
invokespecial io.vertx.core.eventbus.impl.codecs.ReplyExceptionMessageCodec.<init>:()V
putstatic io.vertx.core.eventbus.impl.CodecManager.REPLY_EXCEPTION_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
2: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.vertx.core.eventbus.impl.CodecManager.defaultCodecMap:Ljava/util/concurrent/ConcurrentMap;
3: aload 0
aload 0
bipush 16
anewarray io.vertx.core.eventbus.MessageCodec
dup
iconst_0
getstatic io.vertx.core.eventbus.impl.CodecManager.NULL_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
iconst_1
getstatic io.vertx.core.eventbus.impl.CodecManager.PING_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
iconst_2
getstatic io.vertx.core.eventbus.impl.CodecManager.STRING_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
iconst_3
getstatic io.vertx.core.eventbus.impl.CodecManager.BUFFER_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
iconst_4
getstatic io.vertx.core.eventbus.impl.CodecManager.JSON_OBJECT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
iconst_5
getstatic io.vertx.core.eventbus.impl.CodecManager.JSON_ARRAY_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 6
4: getstatic io.vertx.core.eventbus.impl.CodecManager.BYTE_ARRAY_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 7
getstatic io.vertx.core.eventbus.impl.CodecManager.INT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 8
getstatic io.vertx.core.eventbus.impl.CodecManager.LONG_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 9
getstatic io.vertx.core.eventbus.impl.CodecManager.FLOAT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 10
getstatic io.vertx.core.eventbus.impl.CodecManager.DOUBLE_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 11
5: getstatic io.vertx.core.eventbus.impl.CodecManager.BOOLEAN_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 12
getstatic io.vertx.core.eventbus.impl.CodecManager.SHORT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 13
getstatic io.vertx.core.eventbus.impl.CodecManager.CHAR_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 14
getstatic io.vertx.core.eventbus.impl.CodecManager.BYTE_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
dup
bipush 15
getstatic io.vertx.core.eventbus.impl.CodecManager.REPLY_EXCEPTION_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
aastore
6: invokevirtual io.vertx.core.eventbus.impl.CodecManager.codecs:([Lio/vertx/core/eventbus/MessageCodec;)[Lio/vertx/core/eventbus/MessageCodec;
putfield io.vertx.core.eventbus.impl.CodecManager.systemCodecs:[Lio/vertx/core/eventbus/MessageCodec;
7: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/eventbus/impl/CodecManager;
public io.vertx.core.eventbus.MessageCodec lookupCodec(java.lang.Object, java.lang.String);
descriptor: (Ljava/lang/Object;Ljava/lang/String;)Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ifnull 4
1: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 2
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageCodec
astore 3
start local 3 2: aload 3
ifnonnull 54
3: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "No message codec for name: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
end local 3 4: StackMap locals:
StackMap stack:
aload 1
ifnonnull 7
5: getstatic io.vertx.core.eventbus.impl.CodecManager.NULL_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 6: goto 54
end local 3 StackMap locals:
StackMap stack:
7: aload 1
instanceof java.lang.String
ifeq 10
8: getstatic io.vertx.core.eventbus.impl.CodecManager.STRING_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 9: goto 54
end local 3 StackMap locals:
StackMap stack:
10: aload 1
instanceof io.vertx.core.buffer.Buffer
ifeq 13
11: getstatic io.vertx.core.eventbus.impl.CodecManager.BUFFER_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 12: goto 54
end local 3 StackMap locals:
StackMap stack:
13: aload 1
instanceof io.vertx.core.json.JsonObject
ifeq 16
14: getstatic io.vertx.core.eventbus.impl.CodecManager.JSON_OBJECT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 15: goto 54
end local 3 StackMap locals:
StackMap stack:
16: aload 1
instanceof io.vertx.core.json.JsonArray
ifeq 19
17: getstatic io.vertx.core.eventbus.impl.CodecManager.JSON_ARRAY_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 18: goto 54
end local 3 StackMap locals:
StackMap stack:
19: aload 1
instanceof byte[]
ifeq 22
20: getstatic io.vertx.core.eventbus.impl.CodecManager.BYTE_ARRAY_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 21: goto 54
end local 3 StackMap locals:
StackMap stack:
22: aload 1
instanceof java.lang.Integer
ifeq 25
23: getstatic io.vertx.core.eventbus.impl.CodecManager.INT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 24: goto 54
end local 3 StackMap locals:
StackMap stack:
25: aload 1
instanceof java.lang.Long
ifeq 28
26: getstatic io.vertx.core.eventbus.impl.CodecManager.LONG_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 27: goto 54
end local 3 StackMap locals:
StackMap stack:
28: aload 1
instanceof java.lang.Float
ifeq 31
29: getstatic io.vertx.core.eventbus.impl.CodecManager.FLOAT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 30: goto 54
end local 3 StackMap locals:
StackMap stack:
31: aload 1
instanceof java.lang.Double
ifeq 34
32: getstatic io.vertx.core.eventbus.impl.CodecManager.DOUBLE_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 33: goto 54
end local 3 StackMap locals:
StackMap stack:
34: aload 1
instanceof java.lang.Boolean
ifeq 37
35: getstatic io.vertx.core.eventbus.impl.CodecManager.BOOLEAN_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 36: goto 54
end local 3 StackMap locals:
StackMap stack:
37: aload 1
instanceof java.lang.Short
ifeq 40
38: getstatic io.vertx.core.eventbus.impl.CodecManager.SHORT_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 39: goto 54
end local 3 StackMap locals:
StackMap stack:
40: aload 1
instanceof java.lang.Character
ifeq 43
41: getstatic io.vertx.core.eventbus.impl.CodecManager.CHAR_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 42: goto 54
end local 3 StackMap locals:
StackMap stack:
43: aload 1
instanceof java.lang.Byte
ifeq 46
44: getstatic io.vertx.core.eventbus.impl.CodecManager.BYTE_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
start local 3 45: goto 54
end local 3 StackMap locals:
StackMap stack:
46: aload 1
instanceof io.vertx.core.eventbus.ReplyException
ifeq 51
47: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.defaultCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageCodec
astore 3
start local 3 48: aload 3
ifnonnull 54
49: getstatic io.vertx.core.eventbus.impl.CodecManager.REPLY_EXCEPTION_MESSAGE_CODEC:Lio/vertx/core/eventbus/MessageCodec;
astore 3
50: goto 54
end local 3 51: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.defaultCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageCodec
astore 3
start local 3 52: aload 3
ifnonnull 54
53: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "No message codec for type: "
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.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
54: StackMap locals: io.vertx.core.eventbus.MessageCodec
StackMap stack:
aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 55 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 55 1 body Ljava/lang/Object;
0 55 2 codecName Ljava/lang/String;
2 4 3 codec Lio/vertx/core/eventbus/MessageCodec;
6 7 3 codec Lio/vertx/core/eventbus/MessageCodec;
9 10 3 codec Lio/vertx/core/eventbus/MessageCodec;
12 13 3 codec Lio/vertx/core/eventbus/MessageCodec;
15 16 3 codec Lio/vertx/core/eventbus/MessageCodec;
18 19 3 codec Lio/vertx/core/eventbus/MessageCodec;
21 22 3 codec Lio/vertx/core/eventbus/MessageCodec;
24 25 3 codec Lio/vertx/core/eventbus/MessageCodec;
27 28 3 codec Lio/vertx/core/eventbus/MessageCodec;
30 31 3 codec Lio/vertx/core/eventbus/MessageCodec;
33 34 3 codec Lio/vertx/core/eventbus/MessageCodec;
36 37 3 codec Lio/vertx/core/eventbus/MessageCodec;
39 40 3 codec Lio/vertx/core/eventbus/MessageCodec;
42 43 3 codec Lio/vertx/core/eventbus/MessageCodec;
45 46 3 codec Lio/vertx/core/eventbus/MessageCodec;
48 51 3 codec Lio/vertx/core/eventbus/MessageCodec;
52 55 3 codec Lio/vertx/core/eventbus/MessageCodec;
MethodParameters:
Name Flags
body
codecName
public io.vertx.core.eventbus.MessageCodec getCodec(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageCodec
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 1 1 codecName Ljava/lang/String;
MethodParameters:
Name Flags
codecName
public void registerCodec(io.vertx.core.eventbus.MessageCodec);
descriptor: (Lio/vertx/core/eventbus/MessageCodec;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "codec"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 1
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
ldc "code.name()"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 0
aload 1
invokevirtual io.vertx.core.eventbus.impl.CodecManager.checkSystemCodec:(Lio/vertx/core/eventbus/MessageCodec;)V
3: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
invokeinterface java.util.concurrent.ConcurrentMap.containsKey:(Ljava/lang/Object;)Z
ifeq 5
4: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Already a codec registered with name "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 7 1 codec Lio/vertx/core/eventbus/MessageCodec;
MethodParameters:
Name Flags
codec
public void unregisterCodec(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 3 1 name Ljava/lang/String;
MethodParameters:
Name Flags
name
public <T> void registerDefaultCodec(java.lang.Class<T>, io.vertx.core.eventbus.MessageCodec<T, ?>);
descriptor: (Ljava/lang/Class;Lio/vertx/core/eventbus/MessageCodec;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 2
ldc "codec"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
2: aload 2
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
ldc "code.name()"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 2
invokevirtual io.vertx.core.eventbus.impl.CodecManager.checkSystemCodec:(Lio/vertx/core/eventbus/MessageCodec;)V
4: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.defaultCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.containsKey:(Ljava/lang/Object;)Z
ifeq 6
5: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Already a default codec registered for class "
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
6: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 2
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
invokeinterface java.util.concurrent.ConcurrentMap.containsKey:(Ljava/lang/Object;)Z
ifeq 8
7: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Already a codec registered with name "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
8: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.defaultCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
aload 2
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
9: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 2
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
aload 2
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
10: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 11 1 clazz Ljava/lang/Class<TT;>;
0 11 2 codec Lio/vertx/core/eventbus/MessageCodec<TT;*>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Class<TT;>;Lio/vertx/core/eventbus/MessageCodec<TT;*>;)V
MethodParameters:
Name Flags
clazz
codec
public void unregisterDefaultCodec(java.lang.Class);
descriptor: (Ljava/lang/Class;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.defaultCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageCodec
astore 2
start local 2 2: aload 2
ifnull 4
3: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.userCodecMap:Ljava/util/concurrent/ConcurrentMap;
aload 2
invokeinterface io.vertx.core.eventbus.MessageCodec.name:()Ljava/lang/String;
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
4: StackMap locals: io.vertx.core.eventbus.MessageCodec
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 5 1 clazz Ljava/lang/Class;
2 5 2 codec Lio/vertx/core/eventbus/MessageCodec;
MethodParameters:
Name Flags
clazz
public io.vertx.core.eventbus.MessageCodec[] systemCodecs();
descriptor: ()[Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.eventbus.impl.CodecManager.systemCodecs:[Lio/vertx/core/eventbus/MessageCodec;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/eventbus/impl/CodecManager;
private void checkSystemCodec(io.vertx.core.eventbus.MessageCodec);
descriptor: (Lio/vertx/core/eventbus/MessageCodec;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.core.eventbus.MessageCodec.systemCodecID:()B
iconst_m1
if_icmpeq 2
1: new java.lang.IllegalArgumentException
dup
ldc "Can't register a system codec"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 3 1 codec Lio/vertx/core/eventbus/MessageCodec;
MethodParameters:
Name Flags
codec
private io.vertx.core.eventbus.MessageCodec[] codecs(io.vertx.core.eventbus.MessageCodec[]);
descriptor: ([Lio/vertx/core/eventbus/MessageCodec;)[Lio/vertx/core/eventbus/MessageCodec;
flags: (0x0082) ACC_PRIVATE, ACC_VARARGS
Code:
stack=3, locals=7, args_size=2
start local 0 start local 1 0: aload 1
arraylength
anewarray io.vertx.core.eventbus.MessageCodec
astore 2
start local 2 1: aload 1
dup
astore 6
arraylength
istore 5
iconst_0
istore 4
goto 5
StackMap locals: io.vertx.core.eventbus.impl.CodecManager io.vertx.core.eventbus.MessageCodec[] io.vertx.core.eventbus.MessageCodec[] top int int io.vertx.core.eventbus.MessageCodec[]
StackMap stack:
2: aload 6
iload 4
aaload
astore 3
start local 3 3: aload 2
aload 3
invokeinterface io.vertx.core.eventbus.MessageCodec.systemCodecID:()B
aload 3
aastore
end local 3 4: iinc 4 1
StackMap locals:
StackMap stack:
5: iload 4
iload 5
if_icmplt 2
6: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/eventbus/impl/CodecManager;
0 7 1 codecs [Lio/vertx/core/eventbus/MessageCodec;
1 7 2 arr [Lio/vertx/core/eventbus/MessageCodec;
3 4 3 codec Lio/vertx/core/eventbus/MessageCodec;
MethodParameters:
Name Flags
codecs
}
SourceFile: "CodecManager.java"