Package | Description |
---|---|
io.openmessaging.consumer | |
io.openmessaging.extension |
Modifier and Type | Method and Description |
---|---|
List<Message> |
PullConsumer.batchReceive(String queueName,
QueueMetaData queueMetaData,
MessageReceipt messageReceipt,
long timeout)
Receive message in asynchronous way.
|
Message |
PullConsumer.receive(String queueName,
QueueMetaData queueMetaData,
MessageReceipt messageReceipt,
long timeout)
Receives the next message from the which bind queue,partition and receiptId of this consumer in pull model.
|
Modifier and Type | Method and Description |
---|---|
Set<QueueMetaData> |
Extension.getQueueMetaData(String queueName)
This method used for getting the related queue's meta data, and this method is optional, vendors may not provide
this method based on their implementation.
|
Copyright © 2017–2020 OpenMessaging. All rights reserved.