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()
Returns a string representation of the object.
|
getHeaderBytes, getHeaderLength, getHeaderOffset, getPayloadBytes, getPayloadOffset
createWireMessage, createWireMessage, createWireMessage, decodeUTF8, encodeMBI, encodeMessageId, encodeUTF8, getHeader, getKey, getMessageId, getType, isRetryable, readMBI, setDuplicate
public MqttPublish(byte info, byte[] data) throws MqttException, IOException
info
- the message info bytedata
- the variable header and payload bytesMqttException
IOException
public MqttPublish(String name, MqttMessage message)
protected static byte[] encodePayload(MqttMessage message)
public MqttMessage getMessage()
protected byte getMessageInfo()
MqttWireMessage
getMessageInfo
in class MqttWireMessage
public byte[] getPayload() throws MqttException
MqttWireMessage
getPayload
in class MqttWireMessage
MqttException
public int getPayloadLength()
MqttPersistable
getPayloadLength
in interface MqttPersistable
getPayloadLength
in class MqttPersistableWireMessage
public String getTopicName()
protected byte[] getVariableHeader() throws MqttException
getVariableHeader
in class MqttWireMessage
MqttException
public boolean isMessageIdRequired()
MqttWireMessage
isMessageIdRequired
in class MqttWireMessage
public void setMessageId(int msgId)
MqttWireMessage
setMessageId
in class MqttWireMessage
public String toString()
Object
toString
method returns a
string that "textually represents" this object. The result should be a concise but informative
representation that is easy for a person to read. It is recommended that all subclasses override
this method.
The toString
method for class Object
returns a string consisting of the name of
the class of which the object is an instance, the at-sign character `@
', and the unsigned
hexadecimal representation of the hash code of the object. In other words, this method returns a
string equal to the value of:
getClass().getName() + '@' + Integer.toHexString(hashCode())
toString
in class MqttWireMessage