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

Class RetryProcessor<T extends br.com.anteros.mqtt.codec.MqttMessage>

java.lang.Object

br.com.anteros.mqtt.core.common.RetryProcessor<T>

Type Parameters:

T - MqttMessage

public final class RetryProcessor<T extends br.com.anteros.mqtt.codec.MqttMessage>
extends Object

重试处理器，参考于 netty-mqtt-client

Constructor Summary

Constructors

Constructor	Description
RetryProcessor()

Method Summary

Modifier and Type	Method	Description
void	setHandle(BiConsumer<br.com.anteros.mqtt.codec.MqttFixedHeader,T> runnable)
void	setOriginalMessage(T originalMessage)
void	start(ScheduledThreadPoolExecutor executor)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryProcessor

public RetryProcessor()

Method Detail

start

public void start(ScheduledThreadPoolExecutor executor)

stop

public void stop()

setHandle

public void setHandle(BiConsumer<br.com.anteros.mqtt.codec.MqttFixedHeader,T> runnable)

setOriginalMessage

public void setOriginalMessage(T originalMessage)