Class SqsAckFlow

Inheritance

Object

SqsAckFlow

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Streams.SQS

Assembly: Akka.Streams.SQS.dll

Syntax

public static class SqsAckFlow

Methods

Default(IAmazonSQS, String, SqsAckSettings)

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

Declaration

public static Flow<MessageAction, ISqsAckResult, NotUsed> 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.Flow<MessageAction, ISqsAckResult, Akka.NotUsed>

Grouped(IAmazonSQS, String, SqsAckGroupedSettings)

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

Declaration

public static Flow<MessageAction, ISqsAckResultEntry, NotUsed> 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.Flow<MessageAction, ISqsAckResultEntry, Akka.NotUsed>

GroupedChangeMessageVisibility(IAmazonSQS, String, SqsAckGroupedSettings)

Declaration

public static Flow<ChangeMessageVisibility, SqsChangeMessageVisibilityResultEntry, NotUsed> GroupedChangeMessageVisibility(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.Flow<ChangeMessageVisibility, SqsChangeMessageVisibilityResultEntry, Akka.NotUsed>

GroupedDelete(IAmazonSQS, String, SqsAckGroupedSettings)

Declaration

public static Flow<Delete, SqsDeleteResultEntry, NotUsed> GroupedDelete(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.Flow<Delete, SqsDeleteResultEntry, Akka.NotUsed>