- 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
All Methods Static Methods Instance Methods Concrete Methods 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 tooutput
.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
-
-
-
-
Method Detail
-
packetType
public int packetType()
- Specified by:
packetType
in classMqttPacket<T>
-
packetFlags
public int packetFlags()
- Specified by:
packetFlags
in classMqttPacket<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 classMqttPart
-
encodeMqtt
public Encoder<?,MqttPublish<T>> encodeMqtt(OutputBuffer<?> output, MqttEncoder mqtt)
- Specified by:
encodeMqtt
in classMqttPart
-
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 tooutput
.
-
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)
-
-