Package br.com.anteros.mqtt.core.common

Class MqttPendingPublish

java.lang.Object

br.com.anteros.mqtt.core.common.MqttPendingPublish

public final class MqttPendingPublish
extends Object

MqttPendingPublish，参考于 netty-mqtt-client

Author:

netty

Constructor Summary

Constructors

Constructor	Description
MqttPendingPublish(ByteBuffer payload, br.com.anteros.mqtt.codec.MqttPublishMessage message, br.com.anteros.mqtt.codec.MqttQoS qos)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
br.com.anteros.mqtt.codec.MqttPublishMessage	getMessage()
ByteBuffer	getPayload()
br.com.anteros.mqtt.codec.MqttQoS	getQos()
int	hashCode()
void	onPubAckReceived()
void	onPubCompReceived()
void	setPubRelMessage(br.com.anteros.mqtt.codec.MqttMessage pubRelMessage)
void	startPublishRetransmissionTimer(ScheduledThreadPoolExecutor executor, Consumer<br.com.anteros.mqtt.codec.MqttMessage> sendPacket)
void	startPubRelRetransmissionTimer(ScheduledThreadPoolExecutor executor, Consumer<br.com.anteros.mqtt.codec.MqttMessage> sendPacket)

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttPendingPublish

public MqttPendingPublish(ByteBuffer payload,
                          br.com.anteros.mqtt.codec.MqttPublishMessage message,
                          br.com.anteros.mqtt.codec.MqttQoS qos)

Method Detail

getPayload

public ByteBuffer getPayload()

getMessage

public br.com.anteros.mqtt.codec.MqttPublishMessage getMessage()

getQos

public br.com.anteros.mqtt.codec.MqttQoS getQos()

startPublishRetransmissionTimer

public void startPublishRetransmissionTimer(ScheduledThreadPoolExecutor executor,
                                            Consumer<br.com.anteros.mqtt.codec.MqttMessage> sendPacket)

onPubAckReceived

public void onPubAckReceived()

setPubRelMessage

public void setPubRelMessage(br.com.anteros.mqtt.codec.MqttMessage pubRelMessage)

startPubRelRetransmissionTimer

public void startPubRelRetransmissionTimer(ScheduledThreadPoolExecutor executor,
                                           Consumer<br.com.anteros.mqtt.codec.MqttMessage> sendPacket)

onPubCompReceived

public void onPubCompReceived()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object