gistfile1.java

public void nextTuple() {
		ReceiveMessageRequest rmr = new ReceiveMessageRequest(myQueueUrl);
		rmr.setMaxNumberOfMessages(10);
		List<Message> messages = sqs.receiveMessage(rmr).getMessages();
		for (final Message message : messages) {
			collector.emit(new Values(message.getBody()), message.getReceiptHandle());
		}
	}
	public void ack(Object msgId) {
		sqs.deleteMessageAsync(new DeleteMessageRequest(myQueueUrl, "" + msgId));
	}