org.joyqueue.server.retry.api

接口 MessageRetry<T>

所有超级接口:

LifeCycle, Online, PropertySupplierAware

所有已知子接口:

ConsoleMessageRetry<T>

所有已知实现类:

NullMessageRetry

public interface MessageRetry<T>
extends LifeCycle, PropertySupplierAware

消息重试接口

Created by chengzhiliang on 2018/9/13.

方法概要

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

从接口继承的方法 org.joyqueue.toolkit.lang.LifeCycle

start, stop

从接口继承的方法 org.joyqueue.toolkit.lang.Online

isStarted

从接口继承的方法 org.joyqueue.toolkit.config.PropertySupplierAware

setSupplier

方法详细资料

addRetry

void addRetry(List<RetryMessageModel> retryMessageModelList)
       throws JoyQueueException

增加重试

参数:

retryMessageModelList - 重试实例集合

抛出:

JoyQueueException - 异常时抛出

retrySuccess

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

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

参数:

topic - 主题

app - 应用

messageIds - 消息

抛出:

JoyQueueException - 操作失败时

retryError

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

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

参数:

topic - 主题

app - 应用

messageIds - 消息

抛出:

JoyQueueException - 操作失败时

retryExpire

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

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

参数:

topic - 主题

app - 应用

messageIds - 消息

抛出:

JoyQueueException - 操作失败时

getRetry

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

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

参数:

topic - 主题

app - 应用

count - 条数

startIndex - 起始ID

抛出:

JoyQueueException

countRetry

int countRetry(String topic,
               String app)
        throws JoyQueueException

获取重试数据量

参数:

topic - 主题

app - 应用

返回:

重试数据量

抛出:

JoyQueueException - 操作失败时

setRetryPolicyProvider

void setRetryPolicyProvider(RetryPolicyProvider retryPolicyProvider)

设置重试策略和主题发现

参数:

retryPolicyProvider - 重试策略