Class SqsAckSink

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

Methods

| Improve this Doc View Source

Default(IAmazonSQS, String, SqsAckSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> for ack a single SQS message at a time using a client.

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

Grouped(IAmazonSQS, String, SqsAckGroupedSettings)

Creates a Akka.Streams.Dsl.Sink<TIn, TMat> for ack grouped SQS messages using a client.

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