org.joyqueue.server.retry

类 NullMessageRetry

java.lang.Object

org.joyqueue.server.retry.NullMessageRetry

所有已实现的接口:

MessageRetry<Long>, PropertySupplierAware, LifeCycle, Online

public class NullMessageRetry
extends Object
implements MessageRetry<Long>

Created by chengzhiliang on 2019/4/11.

构造器概要

构造器

构造器和说明
NullMessageRetry()

方法概要

限定符和类型	方法和说明
void	addRetry(List<RetryMessageModel> retryMessageModelList) 增加重试
int	countRetry(String topic, String app) 获取重试数据量
List<RetryMessageModel>	getRetry(String topic, String app, short count, long startIndex) 查询指定主题和个数的重试消息 该接口要求实现类返回非空List, 即要么返回非空List，要么抛出异常
boolean	isStarted()
void	retryError(String topic, String app, Long[] messageIds) 更新重试消息状态到重试错误
void	retryExpire(String topic, String app, Long[] messageIds) 更新重试消息状态为重试过期
void	retrySuccess(String topic, String app, Long[] messageIds) 更新重试消息状态到重试成功
void	setRetryPolicyProvider(RetryPolicyProvider retryPolicyProvider) 设置重试策略和主题发现
void	setSupplier(PropertySupplier supplier)
void	start()
void	stop()

从类继承的方法 java.lang.Object

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

构造器详细资料

NullMessageRetry

public NullMessageRetry()

方法详细资料

start

public void start()
           throws Exception

指定者:

start 在接口中 LifeCycle

抛出:

Exception

stop

public void stop()

指定者:

stop 在接口中 LifeCycle

isStarted

public boolean isStarted()

指定者:

isStarted 在接口中 Online

addRetry

public void addRetry(List<RetryMessageModel> retryMessageModelList)
              throws JoyQueueException

从接口复制的说明: MessageRetry

增加重试

指定者:

addRetry 在接口中 MessageRetry<Long>

参数:

retryMessageModelList - 重试实例集合

抛出:

JoyQueueException - 异常时抛出

retrySuccess

public void retrySuccess(String topic,
                         String app,
                         Long[] messageIds)
                  throws JoyQueueException

从接口复制的说明: MessageRetry

更新重试消息状态到重试成功

指定者:

retrySuccess 在接口中 MessageRetry<Long>

参数:

topic - 主题

app - 应用

messageIds - 消息

抛出:

JoyQueueException - 操作失败时

retryError

public void retryError(String topic,
                       String app,
                       Long[] messageIds)
                throws JoyQueueException

从接口复制的说明: MessageRetry

更新重试消息状态到重试错误

指定者:

retryError 在接口中 MessageRetry<Long>

参数:

topic - 主题

app - 应用

messageIds - 消息

抛出:

JoyQueueException - 操作失败时

retryExpire

public void retryExpire(String topic,
                        String app,
                        Long[] messageIds)
                 throws JoyQueueException

从接口复制的说明: MessageRetry

更新重试消息状态为重试过期

指定者:

retryExpire 在接口中 MessageRetry<Long>

参数:

topic - 主题

app - 应用

messageIds - 消息

抛出:

JoyQueueException - 操作失败时

getRetry

public List<RetryMessageModel> getRetry(String topic,
                                        String app,
                                        short count,
                                        long startIndex)
                                 throws JoyQueueException

从接口复制的说明: MessageRetry

查询指定主题和个数的重试消息 该接口要求实现类返回非空List, 即要么返回非空List，要么抛出异常

指定者:

getRetry 在接口中 MessageRetry<Long>

参数:

topic - 主题

app - 应用

count - 条数

startIndex - 起始ID

抛出:

JoyQueueException

countRetry

public int countRetry(String topic,
                      String app)
               throws JoyQueueException

从接口复制的说明: MessageRetry

获取重试数据量

指定者:

countRetry 在接口中 MessageRetry<Long>

参数:

topic - 主题

app - 应用

返回:

重试数据量

抛出:

JoyQueueException - 操作失败时

setRetryPolicyProvider

public void setRetryPolicyProvider(RetryPolicyProvider retryPolicyProvider)

从接口复制的说明: MessageRetry

设置重试策略和主题发现

指定者:

setRetryPolicyProvider 在接口中 MessageRetry<Long>

参数:

retryPolicyProvider - 重试策略

setSupplier

public void setSupplier(PropertySupplier supplier)

指定者:

setSupplier 在接口中 PropertySupplierAware