io.micronaut.nats.serdes

Class JavaLangNatsMessageSerDes

java.lang.Object

io.micronaut.nats.serdes.JavaLangNatsMessageSerDes

All Implemented Interfaces:

io.micronaut.core.order.Ordered, NatsMessageSerDes<java.lang.Object>

@Singleton
public class JavaLangNatsMessageSerDes
extends java.lang.Object
implements NatsMessageSerDes<java.lang.Object>

Serializes and deserializes standard Java types.

Since:

1.0.0

Author:

jgrimm

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<NatsMessageSerDes>	javaSerDes
static java.lang.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
JavaLangNatsMessageSerDes() Default constructor.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	deserialize(io.nats.client.Message message, io.micronaut.core.type.Argument<java.lang.Object> argument) Deserializes the message into the requested type.
protected NatsMessageSerDes	findSerDes(io.micronaut.core.type.Argument<?> type) Finds the correct serDes based on the type.
protected NatsMessageSerDes<java.lang.Boolean>	getBooleanSerDes()
protected NatsMessageSerDes<byte[]>	getByteArraySerDes()
protected NatsMessageSerDes<java.nio.ByteBuffer>	getByteBufferSerDes()
protected NatsMessageSerDes<java.lang.Double>	getDoubleSerDes()
protected NatsMessageSerDes<java.lang.Float>	getFloatSerDes()
protected NatsMessageSerDes<java.lang.Integer>	getIntegerSerDes()
protected NatsMessageSerDes<java.lang.Long>	getLongSerDes()
int	getOrder()
protected NatsMessageSerDes<java.lang.Short>	getShortSerDes()
protected NatsMessageSerDes<java.lang.String>	getStringSerDes()
protected NatsMessageSerDes<java.util.UUID>	getUUIDSerDes()
byte[]	serialize(java.lang.Object data) Serializes the data into a byte[] to be published to nats.
boolean	supports(io.micronaut.core.type.Argument<java.lang.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 java.lang.Integer ORDER

The order of this serDes.

javaSerDes

protected final java.util.List<NatsMessageSerDes> javaSerDes

Constructor Detail

JavaLangNatsMessageSerDes

public JavaLangNatsMessageSerDes()

Default constructor.

Method Detail

serialize

public byte[] serialize(@Nullable
                        java.lang.Object data)

Description copied from interface: NatsMessageSerDes

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

Specified by:

serialize in interface NatsMessageSerDes<java.lang.Object>

Parameters:

data - The data to serialize

Returns:

The message body

deserialize

public java.lang.Object deserialize(io.nats.client.Message message,
                                    io.micronaut.core.type.Argument<java.lang.Object> argument)

Description copied from interface: NatsMessageSerDes

Deserializes the message into the requested type.

Specified by:

deserialize in interface NatsMessageSerDes<java.lang.Object>

Parameters:

message - The message to deserialize

argument - The type to be returned

Returns:

The deserialized body

supports

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

Description copied from interface: NatsMessageSerDes

Determines if this serdes supports the given type.

Specified by:

supports in interface NatsMessageSerDes<java.lang.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 NatsMessageSerDes 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 NatsMessageSerDes<java.lang.String> getStringSerDes()

Returns:

The serDes that handles String

getShortSerDes

@Nonnull
protected NatsMessageSerDes<java.lang.Short> getShortSerDes()

Returns:

The serDes that handles Short

getIntegerSerDes

@Nonnull
protected NatsMessageSerDes<java.lang.Integer> getIntegerSerDes()

Returns:

The serDes that handles Integer

getLongSerDes

@Nonnull
protected NatsMessageSerDes<java.lang.Long> getLongSerDes()

Returns:

The serDes that handles Long

getFloatSerDes

@Nonnull
protected NatsMessageSerDes<java.lang.Float> getFloatSerDes()

Returns:

The serDes that handles Float

getDoubleSerDes

@Nonnull
protected NatsMessageSerDes<java.lang.Double> getDoubleSerDes()

Returns:

The serDes that handles Double

getByteArraySerDes

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

Returns:

The serDes that handles byte[]

getByteBufferSerDes

@Nonnull
protected NatsMessageSerDes<java.nio.ByteBuffer> getByteBufferSerDes()

Returns:

The serDes that handles ByteBuffer

getUUIDSerDes

@Nonnull
protected NatsMessageSerDes<java.util.UUID> getUUIDSerDes()

Returns:

The serDes that handles UUID

getBooleanSerDes

@Nonnull
protected NatsMessageSerDes<java.lang.Boolean> getBooleanSerDes()

Returns:

The serDes that handles UUID