Class SqsPublishFlow

API to create publishing SQS flows.

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

Methods

| Improve this Doc View Source

Batch(IAmazonSQS, String, SqsPublishBatchSettings)

Creates a Akka.Streams.Dsl.Flow<TIn, TOut, TMat> to publish messages in batches to a SQS queue using a client.

Declaration
public static Flow<IEnumerable<SendMessageRequest>, IReadOnlyList<SqsPublishResultEntry>, NotUsed> 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.Flow<IEnumerable<Amazon.SQS.Model.SendMessageRequest>, IReadOnlyList<SqsPublishResultEntry>, Akka.NotUsed>
| Improve this Doc View Source

Default(IAmazonSQS, String, SqsPublishSettings)

Creates a Akka.Streams.Dsl.Flow<TIn, TOut, TMat> to publish messages to a SQS queue using an client.

Declaration
public static Flow<SendMessageRequest, SqsPublishResult, NotUsed> 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.Flow<Amazon.SQS.Model.SendMessageRequest, SqsPublishResult, Akka.NotUsed>
| Improve this Doc View Source

Grouped(IAmazonSQS, String, SqsPublishGroupedSettings)

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

Declaration
public static Flow<SendMessageRequest, SqsPublishResultEntry, NotUsed> 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.Flow<Amazon.SQS.Model.SendMessageRequest, SqsPublishResultEntry, Akka.NotUsed>