io.micronaut.mqtt.serdes

Interface MqttPayloadSerDes<T>

Type Parameters:

T - The type to be serialized/deserialized

All Superinterfaces:

io.micronaut.core.order.Ordered

All Known Implementing Classes:

JavaLangMqttPayloadSerDes, JsonMqttPayloadSerDes

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

Responsible for serializing and deserializing MQTT message payloads.

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(byte[] payload, io.micronaut.core.type.Argument<T> argument) Deserializes the message into the requested type.
byte[]	serialize(T data) Serializes the data into a byte[] to be published to MQTT.
boolean	supports(io.micronaut.core.type.Argument<T> type) Determines if this serdes supports the given type.

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

getOrder

Method Detail

deserialize

@Nullable
T deserialize(byte[] payload,
                        io.micronaut.core.type.Argument<T> argument)

Deserializes the message into the requested type.

Parameters:

payload - The message to deserialize

argument - The type to be returned

Returns:

The deserialized body

serialize

@Nullable
byte[] serialize(@Nullable
                           T data)

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

Parameters:

data - The data to serialize

Returns:

The message body

supports

boolean supports(io.micronaut.core.type.Argument<T> type)

Determines if this serdes supports the given type.

Parameters:

type - The type

Returns:

True if the type is supported