org.joyqueue.handler.routing.command.archive

类 ArchiveCommand

java.lang.Object

org.joyqueue.handler.routing.command.archive.ArchiveCommand

所有已实现的接口:

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 ArchiveCommand
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/7.

嵌套类概要

从接口继承的嵌套类/接口 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.User	session

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

RESULT

构造器概要

构造器

构造器和说明
ArchiveCommand()

方法概要

限定符和类型	方法和说明
com.jd.laf.web.vertx.response.Response	archive2retry(org.joyqueue.model.domain.Archive archive) 归档转重试
void	clean()
com.jd.laf.web.vertx.response.Response	consume(Object messageId) 查询详情
void	download(String businessId, String messageId, String sendTime, String topic, String messageType) 单个下载
com.jd.laf.web.vertx.response.Response	execute()
com.jd.laf.web.vertx.response.Response	isServerEnabled() 归档服务是否可用
com.jd.laf.web.vertx.response.Response	messageTypes()
com.jd.laf.web.vertx.response.Response	pageQuery(org.joyqueue.model.query.QArchive qArchive) 分页查询
com.jd.laf.web.vertx.response.Response	preview(String businessId, String messageId, String sendTime, String topic, String messageType)
String	type()

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

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

字段详细资料

session

protected org.joyqueue.model.domain.User session

构造器详细资料

ArchiveCommand

public ArchiveCommand()

方法详细资料

messageTypes

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

抛出:

Exception

pageQuery

public com.jd.laf.web.vertx.response.Response pageQuery(org.joyqueue.model.query.QArchive qArchive)
                                                 throws Exception

分页查询

参数:

qArchive -

返回:

抛出:

Exception

consume

public com.jd.laf.web.vertx.response.Response consume(Object messageId)
                                               throws Exception

查询详情

参数:

messageId -

返回:

抛出:

Exception

archive2retry

public com.jd.laf.web.vertx.response.Response archive2retry(org.joyqueue.model.domain.Archive archive)
                                                     throws Exception

归档转重试

参数:

archive -

返回:

抛出:

Exception

download

public void download(String businessId,
                     String messageId,
                     String sendTime,
                     String topic,
                     String messageType)
              throws Exception

单个下载

参数:

-

抛出:

Exception

preview

public com.jd.laf.web.vertx.response.Response preview(String businessId,
                                                      String messageId,
                                                      String sendTime,
                                                      String topic,
                                                      String messageType)
                                               throws Exception

抛出:

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

type

public String type()

指定者:

type 在接口中 com.jd.laf.extension.Type<String>

指定者:

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

clean

public void clean()

指定者:

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