org.joyqueue.handler.routing.command.monitor

类 ConsumeOffsetCommand

java.lang.Object

org.joyqueue.handler.routing.command.monitor.ConsumeOffsetCommand

所有已实现的接口:

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 ConsumeOffsetCommand
extends Object
implements com.jd.laf.web.vertx.Command<com.jd.laf.web.vertx.response.Response>, com.jd.laf.web.vertx.pool.Poolable

嵌套类概要

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

字段概要

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

RESULT

构造器概要

构造器

构造器和说明
ConsumeOffsetCommand()

方法概要

限定符和类型	方法和说明
void	clean()
com.jd.laf.web.vertx.response.Response	execute()
com.jd.laf.web.vertx.response.Response	offsetBound(org.joyqueue.model.domain.Subscribe subscribe, String location) offset
com.jd.laf.web.vertx.response.Response	offsets(org.joyqueue.model.domain.Subscribe subscribe)
com.jd.laf.web.vertx.response.Response	resetByTime(org.joyqueue.model.domain.Subscribe subscribe, String timestamp) Reset partition offset by timestamp
com.jd.laf.web.vertx.response.Response	resetOffsets(org.joyqueue.model.domain.ResetOffsetInfo offsetInfo) Reset offsets for @code subscribe
com.jd.laf.web.vertx.response.Response	resetPartition(org.joyqueue.model.domain.Subscribe subscribe, String partition, String offset) Reset partition offset for @code subscribe

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

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

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

type

构造器详细资料

ConsumeOffsetCommand

public ConsumeOffsetCommand()

方法详细资料

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

offsets

public com.jd.laf.web.vertx.response.Response offsets(org.joyqueue.model.domain.Subscribe subscribe)

offsetBound

public com.jd.laf.web.vertx.response.Response offsetBound(org.joyqueue.model.domain.Subscribe subscribe,
                                                          String location)

offset

resetByTime

public com.jd.laf.web.vertx.response.Response resetByTime(org.joyqueue.model.domain.Subscribe subscribe,
                                                          String timestamp)

Reset partition offset by timestamp

resetPartition

public com.jd.laf.web.vertx.response.Response resetPartition(org.joyqueue.model.domain.Subscribe subscribe,
                                                             String partition,
                                                             String offset)

Reset partition offset for @code subscribe

resetOffsets

public com.jd.laf.web.vertx.response.Response resetOffsets(org.joyqueue.model.domain.ResetOffsetInfo offsetInfo)

Reset offsets for @code subscribe

clean

public void clean()

指定者:

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