Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
ack()
Acknowledge this message.
|
Supplier<CompletionStage<Void>> |
getAck() |
String |
getClientId() |
int |
getMessageId() |
byte[] |
getPayload() |
io.netty.handler.codec.mqtt.MqttQoS |
getQosLevel() |
String |
getTopic() |
boolean |
isDuplicate() |
boolean |
isRetain() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMetadata, getMetadata, getMetadata, getNack, nack, of, of, of, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload
public byte[] getPayload()
getPayload
in interface Message<byte[]>
public CompletionStage<Void> ack()
Message
public Supplier<CompletionStage<Void>> getAck()
getAck
in interface Message<byte[]>
CompletionStage
.public int getMessageId()
public io.netty.handler.codec.mqtt.MqttQoS getQosLevel()
public boolean isDuplicate()
public boolean isRetain()
public String getTopic()
public String getClientId()
Copyright © 2018–2021 SmallRye. All rights reserved.