org.joyqueue.server.retry.api

接口 ConsoleMessageRetry<T>

所有超级接口:

LifeCycle, MessageRetry<T>, Online, PropertySupplierAware

public interface ConsoleMessageRetry<T>
extends MessageRetry<T>

Created by chengzhiliang on 2019/2/20.

方法概要

限定符和类型	方法和说明
void	batchUpdateStatus(RetryQueryCondition retryQueryCondition, RetryStatus status, long updateTime, int updateBy)
ConsumeRetry	getConsumeRetryById(Long id, String topic)
PageResult<ConsumeRetry>	queryConsumeRetryList(RetryQueryCondition retryQueryCondition)
void	updateStatus(String topic, String app, T[] messageId, RetryStatus status, long updateTime, int updateBy)

从接口继承的方法 org.joyqueue.server.retry.api.MessageRetry

addRetry, countRetry, getRetry, retryError, retryExpire, retrySuccess, setRetryPolicyProvider

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

start, stop

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

isStarted

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

setSupplier

方法详细资料

queryConsumeRetryList

PageResult<ConsumeRetry> queryConsumeRetryList(RetryQueryCondition retryQueryCondition)
                                        throws JoyQueueException

抛出:

JoyQueueException

getConsumeRetryById

ConsumeRetry getConsumeRetryById(Long id,
                                 String topic)
                          throws JoyQueueException

抛出:

JoyQueueException

updateStatus

void updateStatus(String topic,
                  String app,
                  T[] messageId,
                  RetryStatus status,
                  long updateTime,
                  int updateBy)
           throws Exception

抛出:

Exception

batchUpdateStatus

void batchUpdateStatus(RetryQueryCondition retryQueryCondition,
                       RetryStatus status,
                       long updateTime,
                       int updateBy)
                throws Exception

抛出:

Exception