io.smallrye.reactive.messaging.mqtt

Class SendingMqttMessage<T>

java.lang.Object

io.smallrye.reactive.messaging.mqtt.SendingMqttMessage<T>

All Implemented Interfaces:

MqttMessage<T>, Message<T>

public final class SendingMqttMessage<T>
extends Object
implements MqttMessage<T>

Field Summary

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

LOGGER

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	ack() Acknowledge this message.
Supplier<CompletionStage<Void>>	getAck()
int	getMessageId()
T	getPayload()
io.netty.handler.codec.mqtt.MqttQoS	getQosLevel()
String	getTopic()
boolean	isDuplicate()
boolean	isRetain()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.smallrye.reactive.messaging.mqtt.MqttMessage

of, of, of, of, of, withAck

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

addMetadata, getMetadata, getMetadata, getNack, nack, nack, of, of, of, unwrap, withMetadata, withMetadata, withNack, withPayload

Method Detail

ack

public CompletionStage<Void> ack()

Description copied from interface: Message

Acknowledge this message.

Specified by:

ack in interface Message<T>

Returns:

a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.

getAck

public Supplier<CompletionStage<Void>> getAck()

Specified by:

getAck in interface Message<T>

Returns:

the supplier used to retrieve the acknowledgement CompletionStage.

getPayload

public T getPayload()

Specified by:

getPayload in interface Message<T>

Returns:

The payload for this message.

getMessageId

public int getMessageId()

Specified by:

getMessageId in interface MqttMessage<T>

getQosLevel

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

Specified by:

getQosLevel in interface MqttMessage<T>

isDuplicate

public boolean isDuplicate()

Specified by:

isDuplicate in interface MqttMessage<T>

isRetain

public boolean isRetain()

Specified by:

isRetain in interface MqttMessage<T>

getTopic

public String getTopic()

Specified by:

getTopic in interface MqttMessage<T>