| Package | Description | 
|---|---|
| io.openmessaging.consumer | |
| io.openmessaging.message | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PullConsumer.ack(MessageReceipt receiptHandle)
Acknowledges the specified and consumed message with the unique message receipt handle. 
 | 
void | 
Consumer.ack(MessageReceipt receipt)
Acknowledges the specified and consumed message with the unique message receipt handle, in the scenario of using
 manual commit. 
 | 
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. 
 | 
void | 
BatchMessageListener.Context.success(MessageReceipt... messages)
Acknowledges the specified and consumed message, which is related to this  
MessageContext. | 
| Modifier and Type | Method and Description | 
|---|---|
MessageReceipt | 
Message.getMessageReceipt()
Get the  
MessageReceipt of this Message, which will be used to acknowledge this message. | 
Copyright © 2017–2020 OpenMessaging. All rights reserved.