io.micronaut.nats.serdes

Class JsonNatsMessageSerDes

java.lang.Object

io.micronaut.nats.serdes.JsonNatsMessageSerDes

All Implemented Interfaces:

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

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

Serializes and deserializes objects as JSON using Jackson.

Since:

1.0.0

Author:

jgrimm

Field Summary

Fields

Modifier and Type	Field and Description
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
JsonNatsMessageSerDes(com.fasterxml.jackson.databind.ObjectMapper objectMapper) 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> type) Deserializes the message into the requested type.
int	getOrder()
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.

Constructor Detail

JsonNatsMessageSerDes

public JsonNatsMessageSerDes(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Default constructor.

Parameters:

objectMapper - The jackson object mapper

Method Detail

deserialize

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

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

type - The type to be returned

Returns:

The deserialized body

serialize

public byte[] serialize(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

getOrder

public int getOrder()

Specified by:

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

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