Module swim.mqtt

Package swim.mqtt

Class MqttPublish<T>

java.lang.Object

swim.mqtt.MqttPart

swim.mqtt.MqttPacket<T>

swim.mqtt.MqttPublish<T>

All Implemented Interfaces:

Debug

public final class MqttPublish<T>
extends MqttPacket<T>
implements Debug

Method Summary

Modifier and Type	Method	Description
static <T> MqttPublish<T>	create(int packetFlags, String topicName, int packetId, MqttEntity<T> payload)
static MqttPublish<Object>	create(String topicName)
static <T> MqttPublish<T>	create(String topicName, int packetId, MqttEntity<T> payload)
static <T> MqttPublish<T>	create(String topicName, MqttEntity<T> payload)
<T> Output<T>	debug(Output<T> output)	Writes a developer readable, debug-formatted string representation of this object to output.
boolean	dup()
MqttPublish<T>	dup(boolean dup)
Encoder<?,MqttPublish<T>>	encodeMqtt(OutputBuffer<?> output, MqttEncoder mqtt)
boolean	equals(Object other)
int	hashCode()
boolean	hasPacketId()
Encoder<?,MqttPublish<T>>	mqttEncoder(MqttEncoder mqtt)
int	packetFlags()
int	packetId()
MqttPublish<T>	packetId(int packetId)
int	packetType()
MqttEntity<T>	payload()
MqttPublish<String>	payload(String content)
<U> MqttPublish<U>	payload(ByteBuffer data)
<U> MqttPublish<U>	payload(Encoder<?,?> content, int length)
<U> MqttPublish<U>	payload(MqttEntity<U> payload)
MqttQoS	qos()
MqttPublish<T>	qos(MqttQoS qos)
boolean	retain()
MqttPublish<T>	retain(boolean retain)
String	topicName()
MqttPublish<T>	topicName(String topicName)
String	toString()

Methods inherited from class swim.mqtt.MqttPart

encodeMqtt, mqttEncoder

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

packetType

public int packetType()

Specified by:

packetType in class MqttPacket<T>

packetFlags

public int packetFlags()

Specified by:

packetFlags in class MqttPacket<T>

retain

public boolean retain()

retain

public MqttPublish<T> retain(boolean retain)

qos

public MqttQoS qos()

qos

public MqttPublish<T> qos(MqttQoS qos)

dup

public boolean dup()

dup

public MqttPublish<T> dup(boolean dup)

topicName

public String topicName()

topicName

public MqttPublish<T> topicName(String topicName)

hasPacketId

public boolean hasPacketId()

packetId

public int packetId()

packetId

public MqttPublish<T> packetId(int packetId)

payload

public MqttEntity<T> payload()

payload

public <U> MqttPublish<U> payload(MqttEntity<U> payload)

payload

public <U> MqttPublish<U> payload(Encoder<?,?> content,
                                  int length)

payload

public <U> MqttPublish<U> payload(ByteBuffer data)

payload

public MqttPublish<String> payload(String content)

mqttEncoder

public Encoder<?,MqttPublish<T>> mqttEncoder(MqttEncoder mqtt)

Specified by:

mqttEncoder in class MqttPart

encodeMqtt

public Encoder<?,MqttPublish<T>> encodeMqtt(OutputBuffer<?> output,
                                                  MqttEncoder mqtt)

Specified by:

encodeMqtt in class MqttPart

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

debug

public <T> Output<T> debug(Output<T> output)

Description copied from interface: Debug

Writes a developer readable, debug-formatted string representation of this object to output.

Specified by:

debug in interface Debug

Returns:

the continuation of the output.

toString

public String toString()

Overrides:

toString in class Object

create

public static <T> MqttPublish<T> create(int packetFlags,
                                        String topicName,
                                        int packetId,
                                        MqttEntity<T> payload)

create

public static <T> MqttPublish<T> create(String topicName,
                                        int packetId,
                                        MqttEntity<T> payload)

create

public static <T> MqttPublish<T> create(String topicName,
                                        MqttEntity<T> payload)

create

public static MqttPublish<Object> create(String topicName)