public class DmsConsumerImpl extends DmsAbstractClient implements DmsConsumer
构造器和说明 |
---|
DmsConsumerImpl()
构造函数
|
DmsConsumerImpl(DmsNetClient netClient)
构造函数
|
限定符和类型 | 方法和说明 |
---|---|
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)
异步消费
|
java.lang.String |
getConsumeId() |
ConsumeMode |
getConsumeMode() |
boolean |
isAutoCommit() |
void |
setAutoCommit(boolean autoCommit)
广播模式,设置自动确认
|
void |
setConsumeId(java.lang.String consumeId)
设置消费实例id
|
void |
setConsumeMode(ConsumeMode consumeMode)
设置消费模式
|
start, stop
public DmsConsumerImpl()
public DmsConsumerImpl(DmsNetClient netClient)
netClient
- netClientpublic 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)
DmsConsumer
consume
在接口中 DmsConsumer
projectId
- 区域/项目IDsak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idpublic 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)
DmsConsumer
consume
在接口中 DmsConsumer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间public 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)
DmsConsumer
consumeAsyn
在接口中 DmsConsumer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idcallback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
public 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)
DmsConsumer
consumeAsyn
在接口中 DmsConsumer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间callback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
public java.util.List<DmsConsumeResult> consume(java.lang.String queueId, java.lang.String groupId, int maxMsgs, int timeWait)
DmsConsumer
consume
在接口中 DmsConsumer
queueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间public java.util.List<DmsConsumeResult> consume(java.lang.String queueId, java.lang.String groupId)
DmsConsumer
consume
在接口中 DmsConsumer
queueId
- 队列idgroupId
- 消费组idpublic void consumeAsyn(java.lang.String queueId, java.lang.String groupId, int maxMsgs, int timeWait, DmsCallBack<java.util.List<DmsConsumeResult>> callback)
DmsConsumer
consumeAsyn
在接口中 DmsConsumer
queueId
- 队列idgroupId
- 消费组idmaxMsgs
- 返回最多消息数timeWait
- 消费等待时间callback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
public void consumeAsyn(java.lang.String queueId, java.lang.String groupId, DmsCallBack<java.util.List<DmsConsumeResult>> callback)
DmsConsumer
consumeAsyn
在接口中 DmsConsumer
queueId
- 队列idgroupId
- 消费组idcallback
- 回调接口DmsBlockedCallBack
,
DmsNonBlockedCallBack
public DmsCommitResult commit(java.lang.String queueId, java.lang.String groupId, DmsCommitRequest commitRequest)
DmsConsumer
commit
在接口中 DmsConsumer
queueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求public void commitAsyn(java.lang.String queueId, java.lang.String groupId, DmsCommitRequest commitRequest, DmsCallBack<DmsCommitResult> callback)
DmsConsumer
commitAsyn
在接口中 DmsConsumer
queueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求callback
- 回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
public DmsCommitResult commit(java.lang.String projectId, java.lang.String ak, java.lang.String sk, java.lang.String queueId, java.lang.String groupId, DmsCommitRequest commitRequest)
DmsConsumer
commit
在接口中 DmsConsumer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求public 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)
DmsConsumer
commitAsyn
在接口中 DmsConsumer
projectId
- 区域/项目IDak
- 用户aksk
- 用户skqueueId
- 队列idgroupId
- 消费组idcommitRequest
- commit请求callback
- 回调DmsBlockedCallBack
,
DmsNonBlockedCallBack
public ConsumeMode getConsumeMode()
public void setConsumeMode(ConsumeMode consumeMode)
setConsumeMode
在接口中 DmsConsumer
consumeMode
- consumeModepublic java.lang.String getConsumeId()
public void setConsumeId(java.lang.String consumeId)
setConsumeId
在接口中 DmsConsumer
consumeId
- consumeIdpublic boolean isAutoCommit()
public void setAutoCommit(boolean autoCommit)
setAutoCommit
在接口中 DmsConsumer
autoCommit
- enableAutoCommit