public class MqttPublish extends MqttPersistableWireMessage
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
Constructor and Description |
---|
MqttPublish(byte info,
byte[] data)
Constructs a new MqttPublish object.
|
MqttPublish(java.lang.String name,
MqttMessage message) |
Modifier and Type | Method and Description |
---|---|
MqttMessage |
getMessage() |
byte[] |
getPayload()
Sub-classes should override this method to supply the payload bytes.
|
int |
getPayloadLength()
Returns the length of the payload.
|
java.lang.String |
getTopicName() |
boolean |
isMessageIdRequired()
Returns whether or not this message needs to include a message ID.
|
void |
setMessageId(int msgId)
Sets the MQTT message ID.
|
java.lang.String |
toString() |
getHeaderBytes, getHeaderLength, getHeaderOffset, getPayloadBytes, getPayloadOffset
createWireMessage, createWireMessage, getHeader, getKey, getMessageId, getType, isRetryable, setDuplicate
public MqttPublish(java.lang.String name, MqttMessage message)
public MqttPublish(byte info, byte[] data) throws MqttException, java.io.IOException
info
- the message info bytedata
- the variable header and payload bytesMqttException
java.io.IOException
public java.lang.String toString()
toString
in class MqttWireMessage
public java.lang.String getTopicName()
public MqttMessage getMessage()
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
public boolean isMessageIdRequired()
MqttWireMessage
isMessageIdRequired
in class MqttWireMessage