com.github.davidmoten.rx.aws

Class Sqs

java.lang.Object

com.github.davidmoten.rx.aws.Sqs

public final class Sqs
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Sqs.SqsBuilder
static class	Sqs.ViaS3Builder

Method Summary

Modifier and Type	Method and Description
static Sqs.SqsBuilder	queueName(String queueName)
static String	sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs, String queueUrl, com.amazonaws.services.s3.AmazonS3Client s3, String bucketName, byte[] message)
static String	sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs, String queueUrl, com.amazonaws.services.s3.AmazonS3Client s3, String bucketName, byte[] message, Callable<String> s3IdFactory)
static String	sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs, String queueUrl, com.amazonaws.services.s3.AmazonS3Client s3, String bucketName, Map<String,String> headers, byte[] message)
static String	sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs, String queueUrl, com.amazonaws.services.s3.AmazonS3Client s3, String bucketName, Map<String,String> headers, byte[] message, Callable<String> s3IdFactory)

Methods inherited from class java.lang.Object

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

Method Detail

sendToQueueUsingS3

public static String sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs,
                                        String queueUrl,
                                        com.amazonaws.services.s3.AmazonS3Client s3,
                                        String bucketName,
                                        Map<String,String> headers,
                                        byte[] message,
                                        Callable<String> s3IdFactory)

sendToQueueUsingS3

public static String sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs,
                                        String queueUrl,
                                        com.amazonaws.services.s3.AmazonS3Client s3,
                                        String bucketName,
                                        byte[] message,
                                        Callable<String> s3IdFactory)

sendToQueueUsingS3

public static String sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs,
                                        String queueUrl,
                                        com.amazonaws.services.s3.AmazonS3Client s3,
                                        String bucketName,
                                        byte[] message)

sendToQueueUsingS3

public static String sendToQueueUsingS3(com.amazonaws.services.sqs.AmazonSQSClient sqs,
                                        String queueUrl,
                                        com.amazonaws.services.s3.AmazonS3Client s3,
                                        String bucketName,
                                        Map<String,String> headers,
                                        byte[] message)

queueName

public static Sqs.SqsBuilder queueName(String queueName)