public class MqttPublishMessage extends Object implements MqttMessage
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<MqttPublishMessage> |
__TYPE_ARG |
Constructor and Description |
---|
MqttPublishMessage(MqttPublishMessage delegate) |
MqttPublishMessage(Object delegate) |
Modifier and Type | Method and Description |
---|---|
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)
Create a concrete instance of a Vert.x publish message
|
boolean |
equals(Object o) |
MqttPublishMessage |
getDelegate() |
int |
hashCode() |
boolean |
isDup() |
boolean |
isRetain() |
int |
messageId() |
static MqttPublishMessage |
newInstance(MqttPublishMessage arg) |
Buffer |
payload() |
io.netty.handler.codec.mqtt.MqttProperties |
properties() |
io.netty.handler.codec.mqtt.MqttQoS |
qosLevel() |
String |
topicName() |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
newInstance
public static final io.vertx.lang.rx.TypeArg<MqttPublishMessage> __TYPE_ARG
public MqttPublishMessage(MqttPublishMessage delegate)
public MqttPublishMessage(Object delegate)
public MqttPublishMessage getDelegate()
getDelegate
in interface MqttMessage
public int messageId()
messageId
in interface MqttMessage
public io.netty.handler.codec.mqtt.MqttQoS qosLevel()
public boolean isDup()
public boolean isRetain()
public String topicName()
public Buffer payload()
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)
messageId
- message identifierqosLevel
- quality of service levelisDup
- if the message is a duplicateisRetain
- if the message needs to be retainedtopicName
- topic on which the message was publishedpayload
- payload messageproperties
- message propertiespublic io.netty.handler.codec.mqtt.MqttProperties properties()
public static MqttPublishMessage newInstance(MqttPublishMessage arg)
Copyright © 2023 Eclipse. All rights reserved.