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 the original non 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

Modifier and Type	Method	Description
void	ack()
static MqttPublishMessage	create(int messageId, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, String topicName, io.netty.buffer.ByteBuf payload, io.netty.handler.codec.mqtt.MqttProperties properties)
boolean	equals(Object o)
io.vertx.mqtt.messages.MqttPublishMessage	getDelegate()
int	hashCode()
boolean	isDup()
boolean	isRetain()
int	messageId()
static MqttPublishMessage	newInstance(io.vertx.mqtt.messages.MqttPublishMessage arg)
Buffer	payload()
io.netty.handler.codec.mqtt.MqttProperties	properties()
io.netty.handler.codec.mqtt.MqttQoS	qosLevel()
String	topicName()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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:

getDelegate in interface MqttMessage

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

messageId

public int messageId()

Specified by:

messageId in interface MqttMessage

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

ack

public void ack()

create

public static MqttPublishMessage create(int messageId,
                                        io.netty.handler.codec.mqtt.MqttQoS qosLevel,
                                        boolean isDup,
                                        boolean isRetain,
                                        String topicName,
                                        io.netty.buffer.ByteBuf payload,
                                        io.netty.handler.codec.mqtt.MqttProperties properties)

Parameters:

messageId - message identifier

qosLevel - quality of service level

isDup - if the message is a duplicate

isRetain - if the message needs to be retained

topicName - topic on which the message was published

payload - payload message

properties - message properties

Returns:

Vert.x publish message

properties

public io.netty.handler.codec.mqtt.MqttProperties properties()

Returns:

MQTT properties

newInstance

public static MqttPublishMessage newInstance(io.vertx.mqtt.messages.MqttPublishMessage arg)