com.github.davidmoten.rx.aws

Class Sqs.SqsBuilder

java.lang.Object

com.github.davidmoten.rx.aws.Sqs.SqsBuilder

Enclosing class:

Sqs

public static final class Sqs.SqsBuilder
extends Object

Method Summary

Modifier and Type	Method and Description
Sqs.ViaS3Builder	bucketName(String bucketName)
Sqs.SqsBuilder	interval(int interval, TimeUnit unit)
Sqs.SqsBuilder	interval(int interval, TimeUnit unit, rx.Scheduler scheduler)
rx.Observable<SqsMessage>	messages()
Sqs.SqsBuilder	sqsFactory(rx.functions.Func0<com.amazonaws.services.sqs.AmazonSQSClient> sqsFactory)
Sqs.SqsBuilder	waitTimes(rx.Observable<? extends Number> waitTimesSeconds, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Method Detail

bucketName

public Sqs.ViaS3Builder bucketName(String bucketName)

sqsFactory

public Sqs.SqsBuilder sqsFactory(rx.functions.Func0<com.amazonaws.services.sqs.AmazonSQSClient> sqsFactory)

waitTimes

public Sqs.SqsBuilder waitTimes(rx.Observable<? extends Number> waitTimesSeconds,
                                TimeUnit unit)

interval

public Sqs.SqsBuilder interval(int interval,
                               TimeUnit unit,
                               rx.Scheduler scheduler)

interval

public Sqs.SqsBuilder interval(int interval,
                               TimeUnit unit)

messages

public rx.Observable<SqsMessage> messages()