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.