io.smallrye.reactive.messaging.mqtt

Interface MqttMessage<T>

All Superinterfaces:

Message<T>

All Known Implementing Classes:

ReceivingMqttMessage, SendingMqttMessage

public interface MqttMessage<T>
extends Message<T>

Field Summary

Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message

LOGGER

Method Summary

Modifier and Type	Method and Description
int	getMessageId()
io.netty.handler.codec.mqtt.MqttQoS	getQosLevel()
String	getTopic()
boolean	isDuplicate()
boolean	isRetain()
static <T> MqttMessage<T>	of(String topic, T payload) Create a message with the given payload and metadata.
static <T> MqttMessage<T>	of(String topic, T payload, io.netty.handler.codec.mqtt.MqttQoS qos)
static <T> MqttMessage<T>	of(String topic, T payload, io.netty.handler.codec.mqtt.MqttQoS qos, boolean retain)
static <T> MqttMessage<T>	of(String topic, T payload, Supplier<CompletionStage<Void>> ack) Create a message with the given payload, metadata and ack function.
static <T> MqttMessage<T>	of(T payload) Create a message with the given payload.
default MqttMessage<T>	withAck(Supplier<CompletionStage<Void>> ack) Creates a new instance of Message with the given acknowledgement supplier.

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message

ack, addMetadata, getAck, getMetadata, getMetadata, getNack, getPayload, nack, nack, of, of, of, unwrap, withMetadata, withMetadata, withNack, withPayload

Method Detail

of

static <T> MqttMessage<T> of(T payload)

Description copied from interface: Message

Create a message with the given payload. No metadata are associated with the message, the acknowledgement and negative acknowledgement are immediate.

Specified by:

of in interface Message<T>

Type Parameters:

T - The type of payload

Parameters:

payload - The payload.

Returns:

A message with the given payload, no metadata, and no-op ack and nack functions.

of

static <T> MqttMessage<T> of(String topic,
                             T payload)

Description copied from interface: Message

Create a message with the given payload and metadata. The acknowledgement and negative-acknowledgement are immediate.

Specified by:

of in interface Message<T>

Type Parameters:

T - The type of payload

Parameters:

topic - The payload, must not be null.

payload - The metadata, if null an empty set of metadata is used.

Returns:

A message with the given payload, metadata and no-op ack and nack functions.

of

static <T> MqttMessage<T> of(String topic,
                             T payload,
                             Supplier<CompletionStage<Void>> ack)

Description copied from interface: Message

Create a message with the given payload, metadata and ack function. Negative-acknowledgement is immediate.

Specified by:

of in interface Message<T>

Type Parameters:

T - the type of payload

Parameters:

topic - The payload, must not be null.

payload - the metadata, if null, empty metadata are used.

ack - The ack function, this will be invoked when the returned messages Message.ack() method is invoked.

Returns:

A message with the given payload and ack function.

of

static <T> MqttMessage<T> of(String topic,
                             T payload,
                             io.netty.handler.codec.mqtt.MqttQoS qos)

of

static <T> MqttMessage<T> of(String topic,
                             T payload,
                             io.netty.handler.codec.mqtt.MqttQoS qos,
                             boolean retain)

withAck

default MqttMessage<T> withAck(Supplier<CompletionStage<Void>> ack)

Description copied from interface: Message

Creates a new instance of Message with the given acknowledgement supplier. The payload, metadata and nack function are taken from the current Message.

Specified by:

withAck in interface Message<T>

Parameters:

ack - the acknowledgement supplier

Returns:

the new instance of Message

getMessageId

int getMessageId()

getQosLevel

io.netty.handler.codec.mqtt.MqttQoS getQosLevel()

isDuplicate

boolean isDuplicate()

isRetain

boolean isRetain()

getTopic

String getTopic()