Top Fields Constructors Methods
io.vertx.core.eventbus.impl

public Class CodecManager

extends Object
Class Inheritance
Imports
io.vertx.core.buffer.Buffer, io.vertx.core.eventbus.EventBus, .MessageCodec, .ReplyException, io.vertx.core.eventbus.impl.codecs.*, io.vertx.core.json.JsonArray, .JsonObject, io.vertx.core.shareddata.impl.ClusterSerializable, java.io.Serializable, java.util.Objects, java.util.concurrent.ConcurrentHashMap, .ConcurrentMap, java.util.function.Function
Author
Tim Fox

Field Summary

Modifier and TypeField and Description
public static final MessageCodec<Boolean, Boolean>
BOOLEAN_MESSAGE_CODEC

public static final MessageCodec<Buffer, Buffer>
BUFFER_MESSAGE_CODEC

public static final MessageCodec<byte[], byte[]>
BYTE_ARRAY_MESSAGE_CODEC

public static final MessageCodec<Byte, Byte>
BYTE_MESSAGE_CODEC

public static final MessageCodec<Character, Character>
CHAR_MESSAGE_CODEC

private volatile Function<String, Boolean>
clusterSerializableCheck

private final ClusterSerializableCodec
clusterSerializableCodec

private volatile Function<Object, String>
codecSelector

private final ConcurrentMap<Class<T>, MessageCodec<S, R>>
defaultCodecMap

public static final MessageCodec<Double, Double>
DOUBLE_MESSAGE_CODEC

public static final MessageCodec<Float, Float>
FLOAT_MESSAGE_CODEC

public static final MessageCodec<Integer, Integer>
INT_MESSAGE_CODEC

public static final MessageCodec<JsonArray, JsonArray>
JSON_ARRAY_MESSAGE_CODEC

public static final MessageCodec<JsonObject, JsonObject>
JSON_OBJECT_MESSAGE_CODEC

public static final MessageCodec<Long, Long>
LONG_MESSAGE_CODEC

public static final MessageCodec<String, String>
NULL_MESSAGE_CODEC

public static final MessageCodec<String, String>
PING_MESSAGE_CODEC

public static final MessageCodec<ReplyException, ReplyException>
REPLY_EXCEPTION_MESSAGE_CODEC

private volatile Function<String, Boolean>
serializableCheck

private final SerializableCodec
serializableCodec

public static final MessageCodec<Short, Short>
SHORT_MESSAGE_CODEC

public static final MessageCodec<String, String>
STRING_MESSAGE_CODEC

private final MessageCodec<S, R>[]
systemCodecs

private final ConcurrentMap<String, MessageCodec<S, R>>
userCodecMap

Constructor Summary

AccessConstructor and Description
public
CodecManager()

Method Summary

Modifier and TypeMethod and Description
public boolean
acceptClusterSerializable(String className)

public boolean
acceptSerializable(String className)

private void
checkSystemCodec(MessageCodec<S, R> codec)

public void
clusterSerializableCheck(Function<String, Boolean> classNamePredicate)

private MessageCodec<S, R>[]
codecs(MessageCodec<S, R>... codecs)

public void
codecSelector(Function<Object, String> selector)

public MessageCodec<S, R>
getCodec(String codecName)

public MessageCodec<S, R>
lookupCodec(Object body, String codecName, boolean local)

public void
registerCodec(MessageCodec<S, R> codec)

public <T> void
registerDefaultCodec(Class<T> clazz, MessageCodec<T, ?> codec)

public void
serializableCheck(Function<String, Boolean> classNamePredicate)

public MessageCodec<S, R>[]
systemCodecs()

public void
unregisterCodec(String name)

public void
unregisterDefaultCodec(Class<T> clazz)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

BOOLEAN_MESSAGE_CODECback to summary
public static final MessageCodec<Boolean, Boolean> BOOLEAN_MESSAGE_CODEC
BUFFER_MESSAGE_CODECback to summary
public static final MessageCodec<Buffer, Buffer> BUFFER_MESSAGE_CODEC
BYTE_ARRAY_MESSAGE_CODECback to summary
public static final MessageCodec<byte[], byte[]> BYTE_ARRAY_MESSAGE_CODEC
BYTE_MESSAGE_CODECback to summary
public static final MessageCodec<Byte, Byte> BYTE_MESSAGE_CODEC
CHAR_MESSAGE_CODECback to summary
public static final MessageCodec<Character, Character> CHAR_MESSAGE_CODEC
clusterSerializableCheckback to summary
private volatile Function<String, Boolean> clusterSerializableCheck
clusterSerializableCodecback to summary
private final ClusterSerializableCodec clusterSerializableCodec
codecSelectorback to summary
private volatile Function<Object, String> codecSelector
defaultCodecMapback to summary
private final ConcurrentMap<Class<T>, MessageCodec<S, R>> defaultCodecMap
DOUBLE_MESSAGE_CODECback to summary
public static final MessageCodec<Double, Double> DOUBLE_MESSAGE_CODEC
FLOAT_MESSAGE_CODECback to summary
public static final MessageCodec<Float, Float> FLOAT_MESSAGE_CODEC
INT_MESSAGE_CODECback to summary
public static final MessageCodec<Integer, Integer> INT_MESSAGE_CODEC
JSON_ARRAY_MESSAGE_CODECback to summary
public static final MessageCodec<JsonArray, JsonArray> JSON_ARRAY_MESSAGE_CODEC
JSON_OBJECT_MESSAGE_CODECback to summary
public static final MessageCodec<JsonObject, JsonObject> JSON_OBJECT_MESSAGE_CODEC
LONG_MESSAGE_CODECback to summary
public static final MessageCodec<Long, Long> LONG_MESSAGE_CODEC
NULL_MESSAGE_CODECback to summary
public static final MessageCodec<String, String> NULL_MESSAGE_CODEC
PING_MESSAGE_CODECback to summary
public static final MessageCodec<String, String> PING_MESSAGE_CODEC
REPLY_EXCEPTION_MESSAGE_CODECback to summary
public static final MessageCodec<ReplyException, ReplyException> REPLY_EXCEPTION_MESSAGE_CODEC
serializableCheckback to summary
private volatile Function<String, Boolean> serializableCheck
serializableCodecback to summary
private final SerializableCodec serializableCodec
SHORT_MESSAGE_CODECback to summary
public static final MessageCodec<Short, Short> SHORT_MESSAGE_CODEC
STRING_MESSAGE_CODECback to summary
public static final MessageCodec<String, String> STRING_MESSAGE_CODEC
systemCodecsback to summary
private final MessageCodec<S, R>[] systemCodecs
userCodecMapback to summary
private final ConcurrentMap<String, MessageCodec<S, R>> userCodecMap

Constructor Detail

CodecManagerback to summary
public CodecManager()

Method Detail

acceptClusterSerializableback to summary
public boolean acceptClusterSerializable(String className)
acceptSerializableback to summary
public boolean acceptSerializable(String className)
checkSystemCodecback to summary
private void checkSystemCodec(MessageCodec<S, R> codec)
clusterSerializableCheckback to summary
public void clusterSerializableCheck(Function<String, Boolean> classNamePredicate)
codecsback to summary
private MessageCodec<S, R>[] codecs(MessageCodec<S, R>... codecs)
codecSelectorback to summary
public void codecSelector(Function<Object, String> selector)
getCodecback to summary
public MessageCodec<S, R> getCodec(String codecName)
lookupCodecback to summary
public MessageCodec<S, R> lookupCodec(Object body, String codecName, boolean local)
registerCodecback to summary
public void registerCodec(MessageCodec<S, R> codec)
registerDefaultCodecback to summary
public <T> void registerDefaultCodec(Class<T> clazz, MessageCodec<T, ?> codec)
serializableCheckback to summary
public void serializableCheck(Function<String, Boolean> classNamePredicate)
systemCodecsback to summary
public MessageCodec<S, R>[] systemCodecs()
unregisterCodecback to summary
public void unregisterCodec(String name)
unregisterDefaultCodecback to summary
public void unregisterDefaultCodec(Class<T> clazz)