| 程序包 | 说明 |
|---|---|
| com.aliyun.mq.http | |
| com.aliyun.mq.http.model.action |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
MQConsumer.ackMessage(List<String> receiptHandles)
Tell server the messages are consumed success.
|
AsyncResult<Void> |
MQConsumer.asyncAckMessage(List<String> receiptHandles,
AsyncCallback<Void> callback)
Async tell server the messages are consumed success.
|
List<Message> |
MQConsumer.consumeMessage(int num,
int pollingSecond)
sync consume message from topic.
|
TopicMessage |
MQProducer.publishMessage(TopicMessage msg)
publish message to topic
|
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
AbstractAction.addSignatureHeader(com.aliyun.mq.http.common.http.RequestMessage request) |
protected com.aliyun.mq.http.common.http.RequestMessage |
AckMessageAction.buildRequest(AckMessageRequest reqObject) |
protected com.aliyun.mq.http.common.http.RequestMessage |
ConsumeMessageAction.buildRequest(ConsumeMessageRequest reqObject) |
protected com.aliyun.mq.http.common.http.RequestMessage |
PublishMessageAction.buildRequest(PublishMessageRequest reqObject) |
protected abstract com.aliyun.mq.http.common.http.RequestMessage |
AbstractAction.buildRequest(T reqObject) |
protected com.aliyun.mq.http.common.http.RequestMessage |
AbstractAction.buildRequestMessage(T reqObject) |
V |
Action.execute(T reqObject) |
V |
AbstractAction.execute(T reqObject) |
AsyncResult<V> |
Action.execute(T reqObject,
AsyncCallback<V> asyncHandler) |
AsyncResult<V> |
AbstractAction.execute(T reqObject,
AsyncCallback<V> asyncHandler) |
AsyncResult<V> |
AbstractAction.executeWithCustomHeaders(T reqObject,
AsyncCallback<V> asyncHandler,
Map<String,String> customHeaders) |
V |
AbstractAction.executeWithCustomHeaders(T reqObject,
Map<String,String> customHeaders) |
Copyright © 2019. All Rights Reserved.