com.rultor.queue

Class SQSQueue

java.lang.Object

com.rultor.queue.SQSQueue

All Implemented Interfaces:

Queue

@Immutable
@Loggable(value=1)
public final class SQSQueue
extends Object
implements Queue

Queue in Amazon SQS.

Since:

1.0

Version:

$Id$

Author:

Yegor Bugayenko (yegor@tpc2.com)

Suppressed Checkstyle violations:

ClassDataAbstractionCoupling (500 lines)

Nested Class Summary

Nested classes/interfaces inherited from interface com.rultor.spi.Queue

Queue.Memory

Constructor Summary

Constructors

Constructor and Description
SQSQueue(SQSClient clnt) Public ctor.

Method Summary

Methods

Modifier and Type	Method and Description
Coordinates	pull(int limit, TimeUnit unit)
void	push(Coordinates work)

Methods inherited from class java.lang.Object

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

Constructor Detail

SQSQueue

public SQSQueue(@NotNull(message="SQS client can\'t be NULL")
        SQSClient clnt)

Public ctor.

Parameters:

clnt - S3 client

Method Detail

push

public void push(@NotNull(message="work can\'t be NULL")
        Coordinates work)

Specified by:

push in interface Queue

pull

@NotNull
@Loggable(value=1,
          limit=2147483647)
public Coordinates pull(int limit,
                                          @NotNull(message="unit can\'t be NULL")
                                          TimeUnit unit)
                 throws InterruptedException

Specified by:

pull in interface Queue

Throws:

InterruptedException