org.joyqueue.handler.routing.command.retry

类 RetryCommand

java.lang.Object

org.joyqueue.handler.routing.command.retry.RetryCommand

所有已实现的接口:

com.jd.laf.extension.Prototype, com.jd.laf.extension.Type<String>, com.jd.laf.web.vertx.Command<com.jd.laf.web.vertx.response.Response>, com.jd.laf.web.vertx.pool.Poolable, Cloneable

public class RetryCommand
extends Object
implements com.jd.laf.web.vertx.Command<com.jd.laf.web.vertx.response.Response>, com.jd.laf.web.vertx.pool.Poolable

Created by wangxiaofei1 on 2018/12/5.

嵌套类概要

从接口继承的嵌套类/接口 com.jd.laf.web.vertx.Command

com.jd.laf.web.vertx.Command.EmptyContinue, com.jd.laf.web.vertx.Command.EmptyHold, com.jd.laf.web.vertx.Command.Result, com.jd.laf.web.vertx.Command.ResultType

字段概要

字段

限定符和类型	字段和说明
protected org.joyqueue.model.domain.Identity	operator
protected RetryService	retryService

从接口继承的字段 com.jd.laf.web.vertx.Command

RESULT

构造器概要

构造器

构造器和说明
RetryCommand()

方法概要

限定符和类型	方法和说明
com.jd.laf.web.vertx.response.Response	batchDelete(org.joyqueue.model.query.QRetry qRetry) 批量删除
com.jd.laf.web.vertx.response.Response	batchRecovery(String ids) 批量恢复
void	clean()
com.jd.laf.web.vertx.response.Response	delete(Long id, String topic)
void	download(Long id, String topic) 单个下载
com.jd.laf.web.vertx.response.Response	execute()
com.jd.laf.web.vertx.response.Response	isServerEnabled() 重试服务是否可用
com.jd.laf.web.vertx.response.Response	pageQuery(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QRetry> qPageQuery)
com.jd.laf.web.vertx.response.Response	recovery(Long id, String topic) 恢复

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

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

从接口继承的方法 com.jd.laf.web.vertx.Command

type

字段详细资料

operator

protected org.joyqueue.model.domain.Identity operator

retryService

protected RetryService retryService

构造器详细资料

RetryCommand

public RetryCommand()

方法详细资料

pageQuery

public com.jd.laf.web.vertx.response.Response pageQuery(org.joyqueue.model.QPageQuery<org.joyqueue.model.query.QRetry> qPageQuery)
                                                 throws Exception

抛出:

Exception

recovery

public com.jd.laf.web.vertx.response.Response recovery(Long id,
                                                       String topic)
                                                throws Exception

恢复

参数:

id -

返回:

抛出:

Exception

download

public void download(Long id,
                     String topic)
              throws Exception

单个下载

参数:

-

抛出:

Exception

delete

public com.jd.laf.web.vertx.response.Response delete(Long id,
                                                     String topic)
                                              throws Exception

抛出:

Exception

batchDelete

public com.jd.laf.web.vertx.response.Response batchDelete(org.joyqueue.model.query.QRetry qRetry)
                                                   throws Exception

批量删除

参数:

qRetry -

返回:

抛出:

Exception

batchRecovery

public com.jd.laf.web.vertx.response.Response batchRecovery(String ids)
                                                     throws Exception

批量恢复

参数:

ids -

返回:

抛出:

Exception

isServerEnabled

public com.jd.laf.web.vertx.response.Response isServerEnabled()
                                                       throws Exception

重试服务是否可用

返回:

抛出:

Exception

execute

public com.jd.laf.web.vertx.response.Response execute()
                                               throws Exception

指定者:

execute 在接口中 com.jd.laf.web.vertx.Command<com.jd.laf.web.vertx.response.Response>

抛出:

Exception

clean

public void clean()

指定者:

clean 在接口中 com.jd.laf.web.vertx.pool.Poolable