org.eclipse.paho.client.mqttv3.internal.wire

Class MqttPublish

java.lang.Object

org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage

org.eclipse.paho.client.mqttv3.internal.wire.MqttPersistableWireMessage

org.eclipse.paho.client.mqttv3.internal.wire.MqttPublish

All Implemented Interfaces:

MqttPersistable

public class MqttPublish
extends MqttPersistableWireMessage

An on-the-wire representation of an MQTT SEND message.

Field Summary

Fields inherited from class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage

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 Summary

Constructors

Constructor and Description
MqttPublish(byte info, byte[] data) Constructs a new MqttPublish object.
MqttPublish(java.lang.String name, MqttMessage message)

Method Summary

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()

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, getHeader, getKey, getMessageId, getType, isRetryable, setDuplicate

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MqttPublish

public MqttPublish(java.lang.String name,
                   MqttMessage message)

MqttPublish

public MqttPublish(byte info,
                   byte[] data)
            throws MqttException,
                   java.io.IOException

Constructs a new MqttPublish object.

Parameters:

info - the message info byte

data - the variable header and payload bytes

Throws:

MqttException

java.io.IOException

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class MqttWireMessage

getTopicName

public java.lang.String getTopicName()

getMessage

public MqttMessage getMessage()

getPayload

public byte[] getPayload()
                  throws MqttException

Description copied from class: MqttWireMessage

Sub-classes should override this method to supply the payload bytes.

Overrides:

getPayload in class MqttWireMessage

Throws:

MqttException

getPayloadLength

public int getPayloadLength()

Description copied from interface: MqttPersistable

Returns the length of the payload.

Specified by:

getPayloadLength in interface MqttPersistable

Overrides:

getPayloadLength in class MqttPersistableWireMessage

Returns:

the payload length.

setMessageId

public void setMessageId(int msgId)

Description copied from class: MqttWireMessage

Sets the MQTT message ID.

Overrides:

setMessageId in class MqttWireMessage

isMessageIdRequired

public boolean isMessageIdRequired()

Description copied from class: MqttWireMessage

Returns whether or not this message needs to include a message ID.

Overrides:

isMessageIdRequired in class MqttWireMessage