io.micronaut.configuration.rabbitmq.serdes

Interface RabbitMessageSerDes<T>

Type Parameters:

T - The type to be serialized/deserialized

All Superinterfaces:

io.micronaut.core.order.Ordered

All Known Implementing Classes:

JavaLangRabbitMessageSerDes, JsonRabbitMessageSerDes

public interface RabbitMessageSerDes<T>
extends io.micronaut.core.order.Ordered

Responsible for serializing and deserializing RabbitMQ message bodies.

Since:

1.1.0

Author:

James Kleeh

Field Summary

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

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Method Summary

Modifier and Type	Method and Description
T	deserialize(RabbitConsumerState consumerState, Class<T> type) Deserializes the message into the requested type.
byte[]	serialize(T data) Serializes the data into a byte[] to be published to RabbitMQ.
boolean	supports(Class<T> type) Determines if this serdes supports the given type.

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

getOrder

Method Detail

deserialize

T deserialize(RabbitConsumerState consumerState,
              Class<T> type)

Deserializes the message into the requested type.

Parameters:

consumerState - The message to deserialize

type - The type to be returned

Returns:

The deserialized body

serialize

byte[] serialize(T data)

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

Parameters:

data - The data to serialize

Returns:

The message body

supports

boolean supports(Class<T> type)

Determines if this serdes supports the given type.

Parameters:

type - The type

Returns:

True if the type is supported