Package io.vertx.mutiny.mqtt.messages
Class MqttPublishMessage
- java.lang.Object
-
- io.vertx.mutiny.mqtt.messages.MqttPublishMessage
-
- All Implemented Interfaces:
MqttMessage
public class MqttPublishMessage extends Object implements MqttMessage
Represents an MQTT PUBLISH message NOTE: This class has been automatically generated from theoriginalnon Mutiny-ified interface using Vert.x codegen.
-
-
Field Summary
Fields Modifier and Type Field Description static TypeArg<MqttPublishMessage>__TYPE_ARG
-
Constructor Summary
Constructors Constructor Description MqttPublishMessage(io.vertx.mqtt.messages.MqttPublishMessage delegate)MqttPublishMessage(Object delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)io.vertx.mqtt.messages.MqttPublishMessagegetDelegate()inthashCode()booleanisDup()booleanisRetain()intmessageId()static MqttPublishMessagenewInstance(io.vertx.mqtt.messages.MqttPublishMessage arg)Bufferpayload()io.netty.handler.codec.mqtt.MqttQoSqosLevel()StringtopicName()StringtoString()
-
-
-
Field Detail
-
__TYPE_ARG
public static final TypeArg<MqttPublishMessage> __TYPE_ARG
-
-
Constructor Detail
-
MqttPublishMessage
public MqttPublishMessage(io.vertx.mqtt.messages.MqttPublishMessage delegate)
-
MqttPublishMessage
public MqttPublishMessage(Object delegate)
-
-
Method Detail
-
getDelegate
public io.vertx.mqtt.messages.MqttPublishMessage getDelegate()
- Specified by:
getDelegatein interfaceMqttMessage
-
messageId
public int messageId()
- Specified by:
messageIdin interfaceMqttMessage- Returns:
- Message identifier
-
qosLevel
public io.netty.handler.codec.mqtt.MqttQoS qosLevel()
- Returns:
- Quality of service level
-
isDup
public boolean isDup()
- Returns:
- If the message is a duplicate
-
isRetain
public boolean isRetain()
- Returns:
- If the message needs to be retained
-
topicName
public String topicName()
- Returns:
- Topic on which the message was published
-
payload
public Buffer payload()
- Returns:
- Payload message
-
newInstance
public static MqttPublishMessage newInstance(io.vertx.mqtt.messages.MqttPublishMessage arg)
-
-