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
void	debug(Output<?> 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)
static <T> MqttPublish<T>	from(int packetFlags, String topicName, int packetId, MqttEntity<T> payload)
static MqttPublish<Object>	from(String topicName)
static <T> MqttPublish<T>	from(String topicName, int packetId, MqttEntity<T> payload)
static <T> MqttPublish<T>	from(String topicName, MqttEntity<T> payload)
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

from

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

from

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

from

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

from

public static MqttPublish<Object> from(String topicName)

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 void debug(Output<?> 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

toString

public String toString()

Overrides:

toString in class Object