@Singleton public class JavaLangRabbitMessageSerDes extends Object implements RabbitMessageSerDes<Object>
Modifier and Type | Field and Description |
---|---|
protected Map<Class,RabbitMessageSerDes> |
javaSerDes |
static Integer |
ORDER
The order of this serDes.
|
Constructor and Description |
---|
JavaLangRabbitMessageSerDes()
Default constructor.
|
public static final Integer ORDER
protected final Map<Class,RabbitMessageSerDes> javaSerDes
public JavaLangRabbitMessageSerDes()
public byte[] serialize(Object data)
RabbitMessageSerDes
serialize
in interface RabbitMessageSerDes<Object>
data
- The data to serializepublic Object deserialize(RabbitConsumerState messageState, Class<Object> type)
RabbitMessageSerDes
deserialize
in interface RabbitMessageSerDes<Object>
messageState
- The message to deserializetype
- The type to be returnedpublic boolean supports(Class<Object> type)
RabbitMessageSerDes
supports
in interface RabbitMessageSerDes<Object>
type
- The typepublic int getOrder()
getOrder
in interface io.micronaut.core.order.Ordered
@Nullable protected RabbitMessageSerDes findSerDes(Class type)
type
- The java type@Nonnull protected RabbitMessageSerDes<String> getStringSerDes()
String
@Nonnull protected RabbitMessageSerDes<Short> getShortSerDes()
Short
@Nonnull protected RabbitMessageSerDes<Integer> getIntegerSerDes()
Integer
@Nonnull protected RabbitMessageSerDes<Long> getLongSerDes()
Long
@Nonnull protected RabbitMessageSerDes<Float> getFloatSerDes()
Float
@Nonnull protected RabbitMessageSerDes<Double> getDoubleSerDes()
Double
@Nonnull protected RabbitMessageSerDes<byte[]> getByteArraySerDes()
@Nonnull protected RabbitMessageSerDes<ByteBuffer> getByteBufferSerDes()
ByteBuffer
@Nonnull protected RabbitMessageSerDes<UUID> getUUIDSerDes()
UUID