public interface DmsConsumer extends DmsClient
限定符和类型 | 方法和说明 |
---|---|
DmsCommitResult |
commit(java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest)
同步消息确认
projectId, ak, sk从配置读取 |
DmsCommitResult |
commit(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest)
同步消息确认
|
void |
commitAsyn(java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest,
DmsCallBack<DmsCommitResult> callback)
异步消息确认
projectId, ak, sk从配置读取 |
void |
commitAsyn(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest,
DmsCallBack<DmsCommitResult> callback)
异步消息确认
|
java.util.List<DmsConsumeResult> |
consume(java.lang.String queueId,
java.lang.String groupId)
同步消费
projectId, ak, sk从配置读取 |
java.util.List<DmsConsumeResult> |
consume(java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait)
同步消费
projectId, ak, sk从配置读取 |
java.util.List<DmsConsumeResult> |
consume(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId)
同步消费
|
java.util.List<DmsConsumeResult> |
consume(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait)
同步消费
|
void |
consumeAsyn(java.lang.String queueId,
java.lang.String groupId,
DmsCallBack<java.util.List<DmsConsumeResult>> callback)
异步消费
projectId, ak, sk从配置读取 |
void |
consumeAsyn(java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait,
DmsCallBack<java.util.List<DmsConsumeResult>> callback)
异步消费
projectId, ak, sk从配置读取 |
void |
consumeAsyn(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId,
DmsCallBack<java.util.List<DmsConsumeResult>> callback)
异步消费
|
void |
consumeAsyn(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait,
DmsCallBack<java.util.List<DmsConsumeResult>> callback)
异步消费
|
void |
setAutoCommit(boolean enableAutoCommit)
广播模式,设置自动确认
|
void |
setConsumeId(java.lang.String consumeId)
设置消费实例id
|
void |
setConsumeMode(ConsumeMode consumeMode)
设置消费模式
|
java.util.List<DmsConsumeResult> consume(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.lang.String groupId, int maxMsgs, int timeWait)
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间java.util.List<DmsConsumeResult> consume(java.lang.String queueId, java.lang.String groupId, int maxMsgs, int timeWait)
queueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间java.util.List<DmsConsumeResult> consume(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.lang.String groupId)
projectId
- 区域/项目IDsak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idjava.util.List<DmsConsumeResult> consume(java.lang.String queueId, java.lang.String groupId)
queueId
- 队列idgroupId
- 消费组idvoid consumeAsyn(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.lang.String groupId, int maxMsgs, int timeWait, DmsCallBack<java.util.List<DmsConsumeResult>> callback)
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间callback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
void consumeAsyn(java.lang.String queueId, java.lang.String groupId, int maxMsgs, int timeWait, DmsCallBack<java.util.List<DmsConsumeResult>> callback)
queueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间callback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
void consumeAsyn(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.lang.String groupId, DmsCallBack<java.util.List<DmsConsumeResult>> callback)
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idcallback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
void consumeAsyn(java.lang.String queueId, java.lang.String groupId, DmsCallBack<java.util.List<DmsConsumeResult>> callback)
queueId
- 队列idgroupId
- 消费组idcallback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
DmsCommitResult commit(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.lang.String groupId, DmsCommitRequest commitRequest)
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求DmsCommitResult commit(java.lang.String queueId, java.lang.String groupId, DmsCommitRequest commitRequest)
queueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求void commitAsyn(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.lang.String groupId, DmsCommitRequest commitRequest, DmsCallBack<DmsCommitResult> callback)
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求callback
- 回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
void commitAsyn(java.lang.String queueId, java.lang.String groupId, DmsCommitRequest commitRequest, DmsCallBack<DmsCommitResult> callback)
queueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求callback
- 回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
void setConsumeId(java.lang.String consumeId)
consumeId
- consumeIdvoid setConsumeMode(ConsumeMode consumeMode)
consumeMode
- consumeModevoid setAutoCommit(boolean enableAutoCommit)
enableAutoCommit
- enableAutoCommit