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

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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 com.blacklocus.qs.QueueItemProvider<com.blacklocus.qs.Message>

Specified by:

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

remove

public void remove()

Specified by:

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

Specified by:

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

hasNext

public boolean hasNext()

Specified by:

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

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