| 程序包 | 说明 |
|---|---|
| com.aliyun.mq.http | |
| com.aliyun.mq.http.model.action | |
| com.aliyun.mq.http.model.serialize |
| 限定符和类型 | 方法和说明 |
|---|---|
AsyncResult<List<Message>> |
MQConsumer.asyncConsumeMessage(int num,
int pollingSecond,
AsyncCallback<List<Message>> callback)
async consume message from topic.
|
List<Message> |
MQConsumer.consumeMessage(int num,
int pollingSecond)
sync consume message from topic.
|
| 限定符和类型 | 方法和说明 |
|---|---|
AsyncResult<List<Message>> |
MQConsumer.asyncConsumeMessage(int num,
int pollingSecond,
AsyncCallback<List<Message>> callback)
async consume message from topic.
|
| 限定符和类型 | 方法和说明 |
|---|---|
protected com.aliyun.mq.http.common.parser.ResultParser<List<Message>> |
ConsumeMessageAction.buildResultParser() |
| 限定符和类型 | 方法和说明 |
|---|---|
List<Message> |
MessageListDeserializer.deserialize(Document doc) |
List<Message> |
MessageListDeserializer.deserialize(InputStream stream) |
Copyright © 2019. All Rights Reserved.