io.smallrye.reactive.messaging.mqtt.server

Class MqttMessage

java.lang.Object

io.smallrye.reactive.messaging.mqtt.server.MqttMessage

All Implemented Interfaces:

Message<byte[]>

public class MqttMessage
extends Object
implements Message<byte[]>

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	ack() Acknowledge this message.
String	getClientId()
int	getMessageId()
byte[]	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 org.eclipse.microprofile.reactive.messaging.Message

addMetadata, getAck, getMetadata, getMetadata, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, withPayload

Method Detail

getPayload

public byte[] getPayload()

Specified by:

getPayload in interface Message<byte[]>

Returns:

The payload for this message.

ack

public CompletionStage<Void> ack()

Description copied from interface: Message

Acknowledge this message.

Specified by:

ack in interface Message<byte[]>

Returns:

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

getMessageId

public int getMessageId()

getQosLevel

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

isDuplicate

public boolean isDuplicate()

isRetain

public boolean isRetain()

getTopic

public String getTopic()

getClientId

public String getClientId()