程序包 | 说明 |
---|---|
com.huawei.dms.client.consume |
限定符和类型 | 方法和说明 |
---|---|
java.util.List<DmsConsumeResult> |
DmsConsumer.consume(java.lang.String queueId,
java.lang.String groupId)
同步消费
projectId, ak, sk从配置读取 |
java.util.List<DmsConsumeResult> |
DmsConsumerImpl.consume(java.lang.String queueId,
java.lang.String groupId) |
java.util.List<DmsConsumeResult> |
DmsConsumer.consume(java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait)
同步消费
projectId, ak, sk从配置读取 |
java.util.List<DmsConsumeResult> |
DmsConsumerImpl.consume(java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait) |
java.util.List<DmsConsumeResult> |
DmsConsumer.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> |
DmsConsumerImpl.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> |
DmsConsumer.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)
同步消费
|
java.util.List<DmsConsumeResult> |
DmsConsumerImpl.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 |
DmsConsumer.consumeAsyn(java.lang.String queueId,
java.lang.String groupId,
DmsCallBack<java.util.List<DmsConsumeResult>> callback)
异步消费
projectId, ak, sk从配置读取 |
void |
DmsConsumerImpl.consumeAsyn(java.lang.String queueId,
java.lang.String groupId,
DmsCallBack<java.util.List<DmsConsumeResult>> callback) |
void |
DmsConsumer.consumeAsyn(java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait,
DmsCallBack<java.util.List<DmsConsumeResult>> callback)
异步消费
projectId, ak, sk从配置读取 |
void |
DmsConsumerImpl.consumeAsyn(java.lang.String queueId,
java.lang.String groupId,
int maxMsgs,
int timeWait,
DmsCallBack<java.util.List<DmsConsumeResult>> callback) |
void |
DmsConsumer.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 |
DmsConsumerImpl.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 |
DmsConsumer.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 |
DmsConsumerImpl.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) |