Class SqsPublishSink

Scala API to create publishing SQS sinks.

Inheritance
Object
SqsPublishSink
Inherited Members
Namespace: Akka.Streams.SQS
Assembly: Akka.Streams.SQS.dll
Syntax
public static class SqsPublishSink

Methods

| Improve this Doc View Source

Batch(IAmazonSQS, String, SqsPublishBatchSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> that accepts an iterable of strings and publish them as messages in batches to a SQS queue using a client. See also: https://getakka.net/articles/streams/builtinstages.html#groupedwithin

Declaration
public static Sink<IEnumerable<string>, Task> Batch(IAmazonSQS client, string queueUrl, SqsPublishBatchSettings settings = null)
Parameters
Type Name Description
Amazon.SQS.IAmazonSQS client
String queueUrl
SqsPublishBatchSettings settings
Returns
Type Description
Akka.Streams.Dsl.Sink<IEnumerable<String>, Task>
| Improve this Doc View Source

BatchedMessageSink(IAmazonSQS, String, SqsPublishBatchSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> to publish messages in batches to a SQS queue using a client. See also: https://getakka.net/articles/streams/builtinstages.html#groupedwithin

Declaration
public static Sink<IEnumerable<SendMessageRequest>, Task> BatchedMessageSink(IAmazonSQS client, string queueUrl, SqsPublishBatchSettings settings = null)
Parameters
Type Name Description
Amazon.SQS.IAmazonSQS client
String queueUrl
SqsPublishBatchSettings settings
Returns
Type Description
Akka.Streams.Dsl.Sink<IEnumerable<Amazon.SQS.Model.SendMessageRequest>, Task>
| Improve this Doc View Source

Default(IAmazonSQS, String, SqsPublishSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> that accepts strings and publishes them as messages to a SQS queue using a client.

Declaration
public static Sink<string, Task> Default(IAmazonSQS client, string queueUrl, SqsPublishSettings settings = null)
Parameters
Type Name Description
Amazon.SQS.IAmazonSQS client
String queueUrl
SqsPublishSettings settings
Returns
Type Description
Akka.Streams.Dsl.Sink<String, Task>
| Improve this Doc View Source

Grouped(IAmazonSQS, String, SqsPublishGroupedSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> that groups strings and publishes them as messages in batches to a SQS queue using a client. See also: https://getakka.net/articles/streams/builtinstages.html#groupedwithin

Declaration
public static Sink<string, Task> Grouped(IAmazonSQS client, string queueUrl, SqsPublishGroupedSettings settings = null)
Parameters
Type Name Description
Amazon.SQS.IAmazonSQS client
String queueUrl
SqsPublishGroupedSettings settings
Returns
Type Description
Akka.Streams.Dsl.Sink<String, Task>
| Improve this Doc View Source

GroupedMessageSink(IAmazonSQS, String, SqsPublishGroupedSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> that groups messages and publishes them in batches to a SQS queue using a client. See also: https://getakka.net/articles/streams/builtinstages.html#groupedwithin

Declaration
public static Sink<SendMessageRequest, Task> GroupedMessageSink(IAmazonSQS client, string queueUrl, SqsPublishGroupedSettings settings = null)
Parameters
Type Name Description
Amazon.SQS.IAmazonSQS client
String queueUrl
SqsPublishGroupedSettings settings
Returns
Type Description
Akka.Streams.Dsl.Sink<Amazon.SQS.Model.SendMessageRequest, Task>
| Improve this Doc View Source

MessageSink(IAmazonSQS, String, SqsPublishSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> that accepts strings and publishes them as messages to a SQS queue using a client.

Declaration
public static Sink<SendMessageRequest, Task> MessageSink(IAmazonSQS client, string queueUrl, SqsPublishSettings settings = null)
Parameters
Type Name Description
Amazon.SQS.IAmazonSQS client
String queueUrl
SqsPublishSettings settings
Returns
Type Description
Akka.Streams.Dsl.Sink<Amazon.SQS.Model.SendMessageRequest, Task>