public class MqttPublish extends MqttPersistableWireMessage
duplicate, MESSAGE_TYPE_CONNACK, MESSAGE_TYPE_CONNECT, MESSAGE_TYPE_DISCONNECT, MESSAGE_TYPE_PINGREQ, MESSAGE_TYPE_PINGRESP, MESSAGE_TYPE_PUBACK, MESSAGE_TYPE_PUBCOMP, MESSAGE_TYPE_PUBLISH, MESSAGE_TYPE_PUBREC, MESSAGE_TYPE_PUBREL, MESSAGE_TYPE_SUBACK, MESSAGE_TYPE_SUBSCRIBE, MESSAGE_TYPE_UNSUBACK, MESSAGE_TYPE_UNSUBSCRIBE, msgId, STRING_ENCODING
Constructor and Description |
---|
MqttPublish(byte info,
byte[] data)
Constructs a new MqttPublish object.
|
MqttPublish(String name,
MqttMessage message) |
Modifier and Type | Method and Description |
---|---|
protected static byte[] |
encodePayload(MqttMessage message) |
MqttMessage |
getMessage() |
protected byte |
getMessageInfo()
Sub-classes should override this to encode the message info.
|
byte[] |
getPayload()
Sub-classes should override this method to supply the payload bytes.
|
int |
getPayloadLength()
Returns the length of the payload.
|
String |
getTopicName() |
protected byte[] |
getVariableHeader() |
boolean |
isMessageIdRequired()
Returns whether or not this message needs to include a message ID.
|
void |
setMessageId(int msgId)
Sets the MQTT message ID.
|
String |
toString() |
getHeaderBytes, getHeaderLength, getHeaderOffset, getPayloadBytes, getPayloadOffset
createWireMessage, createWireMessage, decodeUTF8, encodeMBI, encodeMessageId, encodeUTF8, getHeader, getKey, getMessageId, getType, isRetryable, readMBI, setDuplicate
public MqttPublish(String name, MqttMessage message)
public MqttPublish(byte info, byte[] data) throws MqttException, IOException
info
- the message info bytedata
- the variable header and payload bytesMqttException
IOException
public String toString()
toString
in class MqttWireMessage
protected byte getMessageInfo()
MqttWireMessage
getMessageInfo
in class MqttWireMessage
public String getTopicName()
public MqttMessage getMessage()
protected static byte[] encodePayload(MqttMessage message)
public byte[] getPayload() throws MqttException
MqttWireMessage
getPayload
in class MqttWireMessage
MqttException
public int getPayloadLength()
MqttPersistable
getPayloadLength
in interface MqttPersistable
getPayloadLength
in class MqttPersistableWireMessage
public void setMessageId(int msgId)
MqttWireMessage
setMessageId
in class MqttWireMessage
protected byte[] getVariableHeader() throws MqttException
getVariableHeader
in class MqttWireMessage
MqttException
public boolean isMessageIdRequired()
MqttWireMessage
isMessageIdRequired
in class MqttWireMessage
Copyright © 2019 Eclipse Paho. All rights reserved.