com.blacklocus.qs.aws.sqs

Class AmazonSQSMessageProvider

java.lang.Object

com.blacklocus.qs.aws.sqs.AmazonSQSMessageProvider

All Implemented Interfaces:

com.blacklocus.qs.MessageProvider, com.blacklocus.qs.QueueItemProvider<com.blacklocus.qs.Message>, java.lang.Iterable<java.util.Collection<com.blacklocus.qs.Message>>, java.util.Iterator<java.util.Collection<com.blacklocus.qs.Message>>

public class AmazonSQSMessageProvider
extends java.lang.Object
implements com.blacklocus.qs.MessageProvider

Provide Message instances from an SQS queue.

Constructor Summary

Constructors

Constructor and Description
AmazonSQSMessageProvider(com.amazonaws.services.sqs.AmazonSQS sqs, java.lang.String queueUrl) Create a new MessageProvider instance.

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(com.blacklocus.qs.Message message)
java.lang.String	getQueueUrl() Returns the queue url for this provider.
boolean	hasNext()
java.util.Iterator<java.util.Collection<com.blacklocus.qs.Message>>	iterator()
java.util.List<com.blacklocus.qs.Message>	next()
void	remove()
void	setVisibilityTimeout(com.blacklocus.qs.Message message, java.lang.Integer visibilityTimeoutSeconds)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AmazonSQSMessageProvider

public AmazonSQSMessageProvider(com.amazonaws.services.sqs.AmazonSQS sqs,
                        java.lang.String queueUrl)

Create a new MessageProvider instance.

Parameters:

sqs - AmazonSQS instance to use for communicating with AWS

queueUrl - target queue to pull Message instances from

Method Detail

getQueueUrl

public java.lang.String getQueueUrl()

Returns the queue url for this provider.

Returns:

the queue url for this provider

next

public java.util.List<com.blacklocus.qs.Message> next()

Specified by:

next in interface java.util.Iterator<java.util.Collection<com.blacklocus.qs.Message>>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<java.util.Collection<com.blacklocus.qs.Message>>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<java.util.Collection<com.blacklocus.qs.Message>>

iterator

public java.util.Iterator<java.util.Collection<com.blacklocus.qs.Message>> iterator()

Specified by:

iterator in interface com.blacklocus.qs.QueueItemProvider<com.blacklocus.qs.Message>

Specified by:

iterator in interface java.lang.Iterable<java.util.Collection<com.blacklocus.qs.Message>>

delete

public void delete(com.blacklocus.qs.Message message)

Specified by:

delete in interface com.blacklocus.qs.MessageProvider

setVisibilityTimeout

public void setVisibilityTimeout(com.blacklocus.qs.Message message,
                        java.lang.Integer visibilityTimeoutSeconds)

Specified by:

setVisibilityTimeout in interface com.blacklocus.qs.MessageProvider