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

Class MqttPendingQos2Publish

java.lang.Object

br.com.anteros.mqtt.core.common.MqttPendingQos2Publish

public final class MqttPendingQos2Publish
extends Object

MqttPendingPublish，参考于 netty-mqtt-client

Constructor Summary

Constructors

Constructor	Description
MqttPendingQos2Publish(br.com.anteros.mqtt.codec.MqttPublishMessage incomingPublish, br.com.anteros.mqtt.codec.MqttMessage originalMessage)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
br.com.anteros.mqtt.codec.MqttPublishMessage	getIncomingPublish()
int	hashCode()
void	onPubRelReceived()
void	startPubRecRetransmitTimer(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

MqttPendingQos2Publish

public MqttPendingQos2Publish(br.com.anteros.mqtt.codec.MqttPublishMessage incomingPublish,
                              br.com.anteros.mqtt.codec.MqttMessage originalMessage)

Method Detail

getIncomingPublish

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

startPubRecRetransmitTimer

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

onPubRelReceived

public void onPubRelReceived()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object