程序包 | 说明 |
---|---|
com.huawei.dms.client | |
com.huawei.dms.client.consume | |
com.huawei.dms.client.produce | |
com.huawei.dms.client.utils |
限定符和类型 | 接口和说明 |
---|---|
interface |
MessageListener
push 消费模式需实现
|
限定符和类型 | 类和说明 |
---|---|
class |
DmsBlockedCallBack<T>
阻塞callback类型,在线程池执行响应,不会阻塞业务线程
如果用户callback有阻塞操作,要求使用此类型callback,避免业务线程阻塞: sleep调用 网络请求 文件io 同步等待 ... |
class |
DmsNonBlockedCallBack<T>
非阻塞callback类型,在业务线程池执行响应,要确保callback不包含阻塞动作
如果用户callback有阻塞操作,要求使用com.huawei.dms.client.DmsBlockedCallBack,避免业务线程阻塞: sleep调用 网络请求 文件io 同步等待 ... |
构造器和说明 |
---|
DmsTask(OperEntity operEntity,
DmsCallBack<T> callback)
构造函数
|
限定符和类型 | 方法和说明 |
---|---|
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) |
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) |
限定符和类型 | 方法和说明 |
---|---|
void |
DmsAbstractProducer.produceAsyn(java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback) |
void |
DmsProducer.produceAsyn(java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback)
异步生产接口,一次生产多条,通过用户ak、sk鉴权
projectId, ak, sk从配置读取 |
void |
DmsAbstractProducer.produceAsyn(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback) |
void |
DmsProducer.produceAsyn(java.lang.String projectId,
java.lang.String ak,
java.lang.String sk,
java.lang.String queueId,
java.util.List<DmsMessage> messages,
DmsCallBack<java.util.List<DmsProduceResult>> callback)
异步生产接口,一次生产多条,通过用户ak、sk鉴权
|
限定符和类型 | 方法和说明 |
---|---|
static void |
HttpUtil.postAsyn(io.vertx.core.http.HttpClient httpClient,
java.lang.String host,
int port,
java.lang.String uri,
java.util.Map<java.lang.String,java.lang.String> requestHeader,
java.lang.String requestBody,
DmsCallBack<DmsClientHttpResponse> callback)
异步post
|
static void |
HttpUtil.postAsyn(java.lang.String host,
int port,
java.lang.String uri,
boolean isSsl,
java.util.Map<java.lang.String,java.lang.String> requestHeader,
java.lang.String requestBody,
DmsCallBack<DmsClientHttpResponse> callback)
异步post
|