Skip to content
This repository has been archived by the owner on Dec 3, 2019. It is now read-only.

Commit

Permalink
add comment
Browse files Browse the repository at this point in the history
  • Loading branch information
venkat1109 committed Apr 13, 2017
1 parent fe99734 commit ab62e61
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -314,8 +314,13 @@ private void drainAcks(long timeoutMillis) {
}
}

/**
* Reads and processes upto limit acks from the ack queue.
*
* @param limit
* Max number of acks to read and process.
*/
private void readProcessAcks(int limit) {
// Ack batch size messages if you can
int numToAck = Math.min(ackedMessageQueue.size(), limit);
for (int i = 0; i < numToAck; i++) {
PutMessageAck ack = ackedMessageQueue.poll();
Expand Down

0 comments on commit ab62e61

Please sign in to comment.