程序包 | 说明 |
---|---|
com.huawei.dms.client.consume |
限定符和类型 | 方法和说明 |
---|---|
DmsCommitResult |
DmsConsumer.commit(java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest)
同步消息确认
projectId, ak, sk从配置读取 |
DmsCommitResult |
DmsConsumerImpl.commit(java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest) |
DmsCommitResult |
DmsConsumer.commit(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest)
同步消息确认
|
DmsCommitResult |
DmsConsumerImpl.commit(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest) |
限定符和类型 | 方法和说明 |
---|---|
void |
DmsConsumer.commitAsyn(java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest,
DmsCallBack<DmsCommitResult> callback)
异步消息确认
projectId, ak, sk从配置读取 |
void |
DmsConsumerImpl.commitAsyn(java.lang.String queueId,
java.lang.String groupId,
DmsCommitRequest commitRequest,
DmsCallBack<DmsCommitResult> callback) |
void |
DmsConsumer.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)
异步消息确认
|
void |
DmsConsumerImpl.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) |