io.micronaut.configuration.rabbitmq.serdes

Class JavaLangRabbitMessageSerDes

java.lang.Object

io.micronaut.configuration.rabbitmq.serdes.JavaLangRabbitMessageSerDes

All Implemented Interfaces:

RabbitMessageSerDes<Object>, io.micronaut.core.order.Ordered

@Singleton
public class JavaLangRabbitMessageSerDes
extends Object
implements RabbitMessageSerDes<Object>

Serializes and deserializes standard Java types.

Since:

1.1.0

Author:

James Kleeh

Field Summary

Fields

Modifier and Type	Field and Description
protected List<RabbitMessageSerDes>	javaSerDes
static Integer	ORDER The order of this serDes.

Fields inherited from interface io.micronaut.core.order.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
JavaLangRabbitMessageSerDes() Default constructor.

Method Summary

Modifier and Type	Method and Description
Object	deserialize(RabbitConsumerState messageState, io.micronaut.core.type.Argument<Object> argument) Deserializes the message into the requested type.
protected RabbitMessageSerDes	findSerDes(io.micronaut.core.type.Argument<?> type) Finds the correct serDes based on the type.
protected RabbitMessageSerDes<Boolean>	getBooleanSerDes()
protected RabbitMessageSerDes<byte[]>	getByteArraySerDes()
protected RabbitMessageSerDes<ByteBuffer>	getByteBufferSerDes()
protected RabbitMessageSerDes<Double>	getDoubleSerDes()
protected RabbitMessageSerDes<Float>	getFloatSerDes()
protected RabbitMessageSerDes<Integer>	getIntegerSerDes()
protected RabbitMessageSerDes<Long>	getLongSerDes()
int	getOrder()
protected RabbitMessageSerDes<Short>	getShortSerDes()
protected RabbitMessageSerDes<String>	getStringSerDes()
protected RabbitMessageSerDes<UUID>	getUUIDSerDes()
byte[]	serialize(Object data, MutableBasicProperties properties) Serializes the data into a byte[] to be published to RabbitMQ.
boolean	supports(io.micronaut.core.type.Argument<Object> argument) Determines if this serdes supports the given type.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ORDER

public static final Integer ORDER

The order of this serDes.

javaSerDes

protected final List<RabbitMessageSerDes> javaSerDes

Constructor Detail

JavaLangRabbitMessageSerDes

public JavaLangRabbitMessageSerDes()

Default constructor.

Method Detail

serialize

public byte[] serialize(@Nullable
                        Object data,
                        MutableBasicProperties properties)

Description copied from interface: RabbitMessageSerDes

Serializes the data into a byte[] to be published to RabbitMQ.

Specified by:

serialize in interface RabbitMessageSerDes<Object>

Parameters:

data - The data to serialize

properties - The properties of the message

Returns:

The message body

deserialize

public Object deserialize(RabbitConsumerState messageState,
                          io.micronaut.core.type.Argument<Object> argument)

Description copied from interface: RabbitMessageSerDes

Deserializes the message into the requested type.

Specified by:

deserialize in interface RabbitMessageSerDes<Object>

Parameters:

messageState - The message to deserialize

argument - The type to be returned

Returns:

The deserialized body

supports

public boolean supports(io.micronaut.core.type.Argument<Object> argument)

Description copied from interface: RabbitMessageSerDes

Determines if this serdes supports the given type.

Specified by:

supports in interface RabbitMessageSerDes<Object>

Parameters:

argument - The type

Returns:

True if the type is supported

getOrder

public int getOrder()

Specified by:

getOrder in interface io.micronaut.core.order.Ordered

findSerDes

@Nullable
protected RabbitMessageSerDes findSerDes(io.micronaut.core.type.Argument<?> type)

Finds the correct serDes based on the type.

Parameters:

type - The java type

Returns:

The serdes, or null if none can be found

getStringSerDes

@Nonnull
protected RabbitMessageSerDes<String> getStringSerDes()

Returns:

The serDes that handles String

getShortSerDes

@Nonnull
protected RabbitMessageSerDes<Short> getShortSerDes()

Returns:

The serDes that handles Short

getIntegerSerDes

@Nonnull
protected RabbitMessageSerDes<Integer> getIntegerSerDes()

Returns:

The serDes that handles Integer

getLongSerDes

@Nonnull
protected RabbitMessageSerDes<Long> getLongSerDes()

Returns:

The serDes that handles Long

getFloatSerDes

@Nonnull
protected RabbitMessageSerDes<Float> getFloatSerDes()

Returns:

The serDes that handles Float

getDoubleSerDes

@Nonnull
protected RabbitMessageSerDes<Double> getDoubleSerDes()

Returns:

The serDes that handles Double

getByteArraySerDes

@Nonnull
protected RabbitMessageSerDes<byte[]> getByteArraySerDes()

Returns:

The serDes that handles byte[]

getByteBufferSerDes

@Nonnull
protected RabbitMessageSerDes<ByteBuffer> getByteBufferSerDes()

Returns:

The serDes that handles ByteBuffer

getUUIDSerDes

@Nonnull
protected RabbitMessageSerDes<UUID> getUUIDSerDes()

Returns:

The serDes that handles UUID

getBooleanSerDes

@Nonnull
protected RabbitMessageSerDes<Boolean> getBooleanSerDes()

Returns:

The serDes that handles UUID