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) {
			// probably not the best idea to delete messages synchronously...
			collector.emit(new Values(message.getBody())); 
			sqs.deleteMessage(new DeleteMessageRequest(myQueueUrl, message.getReceiptHandle()));
		}
	
	}