io.micronaut.configuration.rabbitmq.serdes

Class JsonRabbitMessageSerDes

java.lang.Object

io.micronaut.configuration.rabbitmq.serdes.JsonRabbitMessageSerDes

All Implemented Interfaces:

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

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

Serializes and deserializes objects as JSON using Jackson.

Since:

1.1.0

Author:

James Kleeh

Field Summary

Fields

Modifier and Type	Field and Description
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
JsonRabbitMessageSerDes(com.fasterxml.jackson.databind.ObjectMapper objectMapper) Default constructor.

Method Summary

Modifier and Type	Method and Description
Object	deserialize(RabbitConsumerState messageState, io.micronaut.core.type.Argument<Object> type) Deserializes the message into the requested type.
int	getOrder()
byte[]	serialize(Object data, MutableBasicProperties basicProperties) 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.

Constructor Detail

JsonRabbitMessageSerDes

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

Default constructor.

Parameters:

objectMapper - The jackson object mapper

Method Detail

deserialize

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

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

type - The type to be returned

Returns:

The deserialized body

serialize

public byte[] serialize(Object data,
                        MutableBasicProperties basicProperties)

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

basicProperties - The properties of the message

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<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