in src/main/java/com/amazonaws/services/sqs/util/ReceiveQueueBuffer.java [471:491]
synchronized void populateResult(ReceiveMessageFuture future) {
if (!isDone()) {
throw new IllegalStateException("batch is not open");
}
// our messages expired.
if (isExpired()) {
clear();
return;
}
if (messages.isEmpty()) {
return;
}
for (Iterator<Message> iter = messages.iterator(); iter.hasNext() && !future.isFull();) {
Message message = iter.next();
iter.remove();
future.addMessage(message);
}
}