public class io.vertx.core.eventbus.impl.CodecManager extends java.lang.Object
{
public static final io.vertx.core.eventbus.MessageCodec PING_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec NULL_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec STRING_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec BUFFER_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec JSON_OBJECT_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec JSON_ARRAY_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec BYTE_ARRAY_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec INT_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec LONG_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec FLOAT_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec DOUBLE_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec BOOLEAN_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec SHORT_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec CHAR_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec BYTE_MESSAGE_CODEC;
public static final io.vertx.core.eventbus.MessageCodec REPLY_EXCEPTION_MESSAGE_CODEC;
private final io.vertx.core.eventbus.MessageCodec[] systemCodecs;
private final java.util.concurrent.ConcurrentMap userCodecMap;
private final java.util.concurrent.ConcurrentMap defaultCodecMap;
private final io.vertx.core.eventbus.impl.codecs.ClusterSerializableCodec clusterSerializableCodec;
private final io.vertx.core.eventbus.impl.codecs.SerializableCodec serializableCodec;
private volatile java.util.function.Function clusterSerializableCheck;
private volatile java.util.function.Function serializableCheck;
private volatile java.util.function.Function codecSelector;
public void <init>()
{
io.vertx.core.eventbus.impl.codecs.ClusterSerializableCodec v, v;
io.vertx.core.eventbus.MessageCodec[] v, v;
java.util.function.Function v, v, v;
io.vertx.core.eventbus.impl.CodecManager v;
io.vertx.core.eventbus.impl.codecs.SerializableCodec v, v;
java.util.concurrent.ConcurrentHashMap v, v;
io.vertx.core.eventbus.MessageCodec v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap defaultCodecMap> = v;
v = new io.vertx.core.eventbus.impl.codecs.ClusterSerializableCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.ClusterSerializableCodec: void <init>(io.vertx.core.eventbus.impl.CodecManager)>(v);
v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.impl.codecs.ClusterSerializableCodec clusterSerializableCodec> = v;
v = new io.vertx.core.eventbus.impl.codecs.SerializableCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.SerializableCodec: void <init>(io.vertx.core.eventbus.impl.CodecManager)>(v);
v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.impl.codecs.SerializableCodec serializableCodec> = v;
v = staticinvoke <io.vertx.core.eventbus.impl.CodecManager$lambda_new_0__1849: java.util.function.Function bootstrap$()>();
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function clusterSerializableCheck> = v;
v = <io.vertx.core.eventbus.EventBus: java.util.function.Function DEFAULT_SERIALIZABLE_CHECKER>;
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function serializableCheck> = v;
v = staticinvoke <io.vertx.core.eventbus.impl.CodecManager$lambda_new_1__1850: java.util.function.Function bootstrap$()>();
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function codecSelector> = v;
v = newarray (io.vertx.core.eventbus.MessageCodec)[18];
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec NULL_MESSAGE_CODEC>;
v[0] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec PING_MESSAGE_CODEC>;
v[1] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec STRING_MESSAGE_CODEC>;
v[2] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BUFFER_MESSAGE_CODEC>;
v[3] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec JSON_OBJECT_MESSAGE_CODEC>;
v[4] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec JSON_ARRAY_MESSAGE_CODEC>;
v[5] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BYTE_ARRAY_MESSAGE_CODEC>;
v[6] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec INT_MESSAGE_CODEC>;
v[7] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec LONG_MESSAGE_CODEC>;
v[8] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec FLOAT_MESSAGE_CODEC>;
v[9] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec DOUBLE_MESSAGE_CODEC>;
v[10] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BOOLEAN_MESSAGE_CODEC>;
v[11] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec SHORT_MESSAGE_CODEC>;
v[12] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec CHAR_MESSAGE_CODEC>;
v[13] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BYTE_MESSAGE_CODEC>;
v[14] = v;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec REPLY_EXCEPTION_MESSAGE_CODEC>;
v[15] = v;
v = v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.impl.codecs.ClusterSerializableCodec clusterSerializableCodec>;
v[16] = v;
v = v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.impl.codecs.SerializableCodec serializableCodec>;
v[17] = v;
v = specialinvoke v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec[] codecs(io.vertx.core.eventbus.MessageCodec[])>(v);
v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec[] systemCodecs> = v;
return;
}
public io.vertx.core.eventbus.MessageCodec lookupCodec(java.lang.Object, java.lang.String, boolean)
{
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.function.Function v;
java.util.concurrent.ConcurrentMap v, v;
io.vertx.core.eventbus.impl.CodecManager v;
java.lang.String v, v, v, v;
java.lang.IllegalArgumentException v;
io.vertx.core.eventbus.MessageCodec v;
java.lang.Class v, v, v, v, v;
java.lang.Object v, v, v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.String;
v := @parameter: boolean;
if v == null goto label;
virtualinvoke v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec getCodec(java.lang.String)>(v);
goto label;
label:
if v != null goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec NULL_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.String;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec STRING_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof io.vertx.core.buffer.Buffer;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BUFFER_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof io.vertx.core.json.JsonObject;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec JSON_OBJECT_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof io.vertx.core.json.JsonArray;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec JSON_ARRAY_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof byte[];
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BYTE_ARRAY_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Integer;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec INT_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Long;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec LONG_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Float;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec FLOAT_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Double;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec DOUBLE_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Boolean;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BOOLEAN_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Short;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec SHORT_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Character;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec CHAR_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof java.lang.Byte;
if v == 0 goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BYTE_MESSAGE_CODEC>;
goto label;
label:
v = v instanceof io.vertx.core.eventbus.ReplyException;
if v == 0 goto label;
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap defaultCodecMap>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec REPLY_EXCEPTION_MESSAGE_CODEC>;
goto label;
label:
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap defaultCodecMap>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function codecSelector>;
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec getCodec(java.lang.String)>(v);
goto label;
label:
v = v instanceof io.vertx.core.shareddata.impl.ClusterSerializable;
if v == 0 goto label;
if v != 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = virtualinvoke v.<io.vertx.core.eventbus.impl.CodecManager: boolean acceptClusterSerializable(java.lang.String)>(v);
if v == 0 goto label;
label:
v = v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.impl.codecs.ClusterSerializableCodec clusterSerializableCodec>;
goto label;
label:
v = v instanceof java.io.Serializable;
if v == 0 goto label;
if v != 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = virtualinvoke v.<io.vertx.core.eventbus.impl.CodecManager: boolean acceptSerializable(java.lang.String)>(v);
if v == 0 goto label;
label:
v = v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.impl.codecs.SerializableCodec serializableCodec>;
label:
if v != null goto label;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No message codec for type: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public io.vertx.core.eventbus.MessageCodec getCodec(java.lang.String)
{
io.vertx.core.eventbus.impl.CodecManager v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ConcurrentMap v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public void registerCodec(io.vertx.core.eventbus.MessageCodec)
{
java.lang.IllegalStateException v;
java.util.concurrent.ConcurrentMap v, v;
io.vertx.core.eventbus.MessageCodec v;
io.vertx.core.eventbus.impl.CodecManager v;
java.lang.String v, v, v, v, v;
boolean v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: io.vertx.core.eventbus.MessageCodec;
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "codec");
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "code.name()");
specialinvoke v.<io.vertx.core.eventbus.impl.CodecManager: void checkSystemCodec(io.vertx.core.eventbus.MessageCodec)>(v);
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = new java.lang.IllegalStateException;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Already a codec registered with name \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void unregisterCodec(java.lang.String)
{
java.lang.String v;
io.vertx.core.eventbus.impl.CodecManager v;
java.util.concurrent.ConcurrentMap v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.lang.String;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
return;
}
public void registerDefaultCodec(java.lang.Class, io.vertx.core.eventbus.MessageCodec)
{
java.lang.IllegalStateException v, v;
java.util.concurrent.ConcurrentMap v, v, v, v;
io.vertx.core.eventbus.impl.CodecManager v;
java.lang.String v, v, v, v, v, v;
boolean v, v;
io.vertx.core.eventbus.MessageCodec v;
java.lang.Class v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.lang.Class;
v := @parameter: io.vertx.core.eventbus.MessageCodec;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "codec");
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "code.name()");
specialinvoke v.<io.vertx.core.eventbus.impl.CodecManager: void checkSystemCodec(io.vertx.core.eventbus.MessageCodec)>(v);
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap defaultCodecMap>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Already a default codec registered for class \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = new java.lang.IllegalStateException;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Already a codec registered with name \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap defaultCodecMap>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void unregisterDefaultCodec(java.lang.Class)
{
io.vertx.core.eventbus.impl.CodecManager v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ConcurrentMap v, v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.lang.Class;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap defaultCodecMap>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.concurrent.ConcurrentMap userCodecMap>;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: java.lang.String name()>();
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
label:
return;
}
public io.vertx.core.eventbus.MessageCodec[] systemCodecs()
{
io.vertx.core.eventbus.MessageCodec[] v;
io.vertx.core.eventbus.impl.CodecManager v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v = v.<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec[] systemCodecs>;
return v;
}
private void checkSystemCodec(io.vertx.core.eventbus.MessageCodec)
{
io.vertx.core.eventbus.MessageCodec v;
byte v;
io.vertx.core.eventbus.impl.CodecManager v;
int v;
java.lang.IllegalArgumentException v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: io.vertx.core.eventbus.MessageCodec;
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: byte systemCodecID()>();
v = (int) -1;
if v == v goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Can\'t register a system codec");
throw v;
label:
return;
}
private transient io.vertx.core.eventbus.MessageCodec[] codecs(io.vertx.core.eventbus.MessageCodec[])
{
io.vertx.core.eventbus.MessageCodec[] v, v;
io.vertx.core.eventbus.MessageCodec v;
byte v;
io.vertx.core.eventbus.impl.CodecManager v;
int v, v, v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: io.vertx.core.eventbus.MessageCodec[];
v = lengthof v;
v = newarray (io.vertx.core.eventbus.MessageCodec)[v];
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<io.vertx.core.eventbus.MessageCodec: byte systemCodecID()>();
v[v] = v;
v = v + 1;
goto label;
label:
return v;
}
public void clusterSerializableCheck(java.util.function.Function)
{
java.lang.Object v;
java.util.function.Function v;
io.vertx.core.eventbus.impl.CodecManager v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.util.function.Function;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function clusterSerializableCheck> = v;
return;
}
public boolean acceptClusterSerializable(java.lang.String)
{
io.vertx.core.eventbus.impl.CodecManager v;
java.lang.Object v;
java.lang.String v;
java.util.function.Function v;
boolean v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function clusterSerializableCheck>;
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
return v;
}
public void serializableCheck(java.util.function.Function)
{
java.lang.Object v;
java.util.function.Function v;
io.vertx.core.eventbus.impl.CodecManager v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.util.function.Function;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function serializableCheck> = v;
return;
}
public boolean acceptSerializable(java.lang.String)
{
io.vertx.core.eventbus.impl.CodecManager v;
java.lang.Object v;
java.lang.String v;
java.util.function.Function v;
boolean v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.lang.String;
v = v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function serializableCheck>;
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
return v;
}
public void codecSelector(java.util.function.Function)
{
java.lang.Object v;
java.util.function.Function v;
io.vertx.core.eventbus.impl.CodecManager v;
v := @this: io.vertx.core.eventbus.impl.CodecManager;
v := @parameter: java.util.function.Function;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<io.vertx.core.eventbus.impl.CodecManager: java.util.function.Function codecSelector> = v;
return;
}
static void <clinit>()
{
io.vertx.core.eventbus.impl.codecs.ShortMessageCodec v;
io.vertx.core.eventbus.impl.codecs.ByteArrayMessageCodec v;
io.vertx.core.eventbus.impl.codecs.NullMessageCodec v;
io.vertx.core.eventbus.impl.codecs.ReplyExceptionMessageCodec v;
io.vertx.core.eventbus.impl.codecs.DoubleMessageCodec v;
io.vertx.core.eventbus.impl.codecs.FloatMessageCodec v;
io.vertx.core.eventbus.impl.codecs.LongMessageCodec v;
io.vertx.core.eventbus.impl.codecs.PingMessageCodec v;
io.vertx.core.eventbus.impl.codecs.IntMessageCodec v;
io.vertx.core.eventbus.impl.codecs.StringMessageCodec v;
io.vertx.core.eventbus.impl.codecs.JsonObjectMessageCodec v;
io.vertx.core.eventbus.impl.codecs.JsonArrayMessageCodec v;
io.vertx.core.eventbus.impl.codecs.BufferMessageCodec v;
io.vertx.core.eventbus.impl.codecs.BooleanMessageCodec v;
io.vertx.core.eventbus.impl.codecs.CharMessageCodec v;
io.vertx.core.eventbus.impl.codecs.ByteMessageCodec v;
v = new io.vertx.core.eventbus.impl.codecs.PingMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.PingMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec PING_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.NullMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.NullMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec NULL_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.StringMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.StringMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec STRING_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.BufferMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.BufferMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BUFFER_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.JsonObjectMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.JsonObjectMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec JSON_OBJECT_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.JsonArrayMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.JsonArrayMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec JSON_ARRAY_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.ByteArrayMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.ByteArrayMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BYTE_ARRAY_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.IntMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.IntMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec INT_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.LongMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.LongMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec LONG_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.FloatMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.FloatMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec FLOAT_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.DoubleMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.DoubleMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec DOUBLE_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.BooleanMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.BooleanMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BOOLEAN_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.ShortMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.ShortMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec SHORT_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.CharMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.CharMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec CHAR_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.ByteMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.ByteMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec BYTE_MESSAGE_CODEC> = v;
v = new io.vertx.core.eventbus.impl.codecs.ReplyExceptionMessageCodec;
specialinvoke v.<io.vertx.core.eventbus.impl.codecs.ReplyExceptionMessageCodec: void <init>()>();
<io.vertx.core.eventbus.impl.CodecManager: io.vertx.core.eventbus.MessageCodec REPLY_EXCEPTION_MESSAGE_CODEC> = v;
return;
}
}