io.micronaut.mqtt.serdes

Class JsonMqttPayloadSerDes

java.lang.Object

io.micronaut.mqtt.serdes.JsonMqttPayloadSerDes

All Implemented Interfaces:

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

@Singleton
public class JsonMqttPayloadSerDes
extends java.lang.Object
implements MqttPayloadSerDes<java.lang.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 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
JsonMqttPayloadSerDes(com.fasterxml.jackson.databind.ObjectMapper objectMapper) Default constructor.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	deserialize(byte[] payload, 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 MQTT.
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

JsonMqttPayloadSerDes

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

Default constructor.

Parameters:

objectMapper - The jackson object mapper

Method Detail

deserialize

public java.lang.Object deserialize(byte[] payload,
                                    io.micronaut.core.type.Argument<java.lang.Object> type)

Description copied from interface: MqttPayloadSerDes

Deserializes the message into the requested type.

Specified by:

deserialize in interface MqttPayloadSerDes<java.lang.Object>

Parameters:

payload - 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: MqttPayloadSerDes

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

Specified by:

serialize in interface MqttPayloadSerDes<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: MqttPayloadSerDes

Determines if this serdes supports the given type.

Specified by:

supports in interface MqttPayloadSerDes<java.lang.Object>

Parameters:

argument - The type

Returns:

True if the type is supported