io.micronaut.mqtt.serdes

Class JavaLangMqttPayloadSerDes

java.lang.Object

io.micronaut.mqtt.serdes.JavaLangMqttPayloadSerDes

All Implemented Interfaces:

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

@Singleton
public class JavaLangMqttPayloadSerDes
extends java.lang.Object
implements MqttPayloadSerDes<java.lang.Object>

Serializes and deserializes standard Java types.

Since:

1.1.0

Author:

James Kleeh

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<MqttPayloadSerDes>	javaSerDes
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
JavaLangMqttPayloadSerDes() Default constructor.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	deserialize(byte[] payload, io.micronaut.core.type.Argument<java.lang.Object> argument) Deserializes the message into the requested type.
protected MqttPayloadSerDes	findSerDes(io.micronaut.core.type.Argument<?> type) Finds the correct serDes based on the type.
protected MqttPayloadSerDes<java.lang.Boolean>	getBooleanSerDes()
protected MqttPayloadSerDes<byte[]>	getByteArraySerDes()
protected MqttPayloadSerDes<java.nio.ByteBuffer>	getByteBufferSerDes()
protected MqttPayloadSerDes<java.lang.Double>	getDoubleSerDes()
protected MqttPayloadSerDes<java.lang.Float>	getFloatSerDes()
protected MqttPayloadSerDes<java.lang.Integer>	getIntegerSerDes()
protected MqttPayloadSerDes<java.lang.Long>	getLongSerDes()
int	getOrder()
protected MqttPayloadSerDes<java.lang.Short>	getShortSerDes()
protected MqttPayloadSerDes<java.lang.String>	getStringSerDes()
protected MqttPayloadSerDes<java.util.UUID>	getUUIDSerDes()
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.

javaSerDes

protected final java.util.List<MqttPayloadSerDes> javaSerDes

Constructor Detail

JavaLangMqttPayloadSerDes

public JavaLangMqttPayloadSerDes()

Default constructor.

Method Detail

serialize

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

deserialize

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

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

argument - The type to be returned

Returns:

The deserialized body

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

getOrder

public int getOrder()

Specified by:

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

findSerDes

@Nullable
protected MqttPayloadSerDes findSerDes(io.micronaut.core.type.Argument<?> type)

Finds the correct serDes based on the type.

Parameters:

type - The java type

Returns:

The serdes, or null if none can be found

getStringSerDes

@Nonnull
protected MqttPayloadSerDes<java.lang.String> getStringSerDes()

Returns:

The serDes that handles String

getShortSerDes

@Nonnull
protected MqttPayloadSerDes<java.lang.Short> getShortSerDes()

Returns:

The serDes that handles Short

getIntegerSerDes

@Nonnull
protected MqttPayloadSerDes<java.lang.Integer> getIntegerSerDes()

Returns:

The serDes that handles Integer

getLongSerDes

@Nonnull
protected MqttPayloadSerDes<java.lang.Long> getLongSerDes()

Returns:

The serDes that handles Long

getFloatSerDes

@Nonnull
protected MqttPayloadSerDes<java.lang.Float> getFloatSerDes()

Returns:

The serDes that handles Float

getDoubleSerDes

@Nonnull
protected MqttPayloadSerDes<java.lang.Double> getDoubleSerDes()

Returns:

The serDes that handles Double

getByteArraySerDes

@Nonnull
protected MqttPayloadSerDes<byte[]> getByteArraySerDes()

Returns:

The serDes that handles byte[]

getByteBufferSerDes

@Nonnull
protected MqttPayloadSerDes<java.nio.ByteBuffer> getByteBufferSerDes()

Returns:

The serDes that handles ByteBuffer

getUUIDSerDes

@Nonnull
protected MqttPayloadSerDes<java.util.UUID> getUUIDSerDes()

Returns:

The serDes that handles UUID

getBooleanSerDes

@Nonnull
protected MqttPayloadSerDes<java.lang.Boolean> getBooleanSerDes()

Returns:

The serDes that handles UUID