|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
org.eclipse.paho.client.mqttv3.internal.wire.MqttPersistableWireMessage
org.eclipse.paho.client.mqttv3.internal.wire.MqttPublish
public class MqttPublish
An on-the-wire representation of an MQTT SEND message.
Field Summary |
---|
Fields inherited from class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage |
---|
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 Summary | |
---|---|
MqttPublish(byte info,
byte[] data)
Constructs a new MqttPublish object. |
|
MqttPublish(String name,
MqttMessage message)
|
Method Summary | |
---|---|
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()
|
Methods inherited from class org.eclipse.paho.client.mqttv3.internal.wire.MqttPersistableWireMessage |
---|
getHeaderBytes, getHeaderLength, getHeaderOffset, getPayloadBytes, getPayloadOffset |
Methods inherited from class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage |
---|
createWireMessage, createWireMessage, decodeUTF8, encodeMBI, encodeMessageId, encodeUTF8, getHeader, getKey, getMessageId, getType, isRetryable, readMBI, setDuplicate |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
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 bytes
MqttException
IOException
Method Detail |
---|
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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |