Namespace Akka.Streams.SQS

Classes

ChangeMessageVisibility

Change the visibility timeout of the message. The maximum allowed timeout value is 12 hours. See: https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ChangeMessageVisibility.html

Delete

Delete the message from the queue. See: https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_DeleteMessage.html

Ignore

MessageAction

SqsAckBatchSettings

SqsAckFlow

SqsAckGroupedSettings

SqsAckSettings

SqsAckSink

SqsBatchException

SqsChangeMessageVisibilityResult

ChangeMessageVisibility acknowledgement.

SqsChangeMessageVisibilityResultEntry

ChangeMessageVisibility acknowledgement within a batch

SqsDeleteResult

Delete acknowledgment.

SqsDeleteResultEntry

Delete acknowledgement within a batch.

SqsIgnoreResult

Ignore acknowledgment No requests are executed on the SQS service for ignore messageAction. Its result is Akka.NotUsed and the responseMetadata is always empty

SqsIgnoreResultEntry

Ignore acknowledgment within a batch No requests are executed on the SQS service for ignore messageAction. Its result is Akka.NotUsed and the responseMetadata is always empty

SqsPublishBatchSettings

SqsPublishFlow

API to create publishing SQS flows.

SqsPublishGroupedSettings

SqsPublishResult

Messages returned by a SqsPublishFlow.

SqsPublishResultEntry

Messages returned by a Grouped(IAmazonSQS, String, SqsPublishGroupedSettings) or .

SqsPublishSettings

SqsPublishSink

Scala API to create publishing SQS sinks.

SqsSource

API to create SQS sources.

SqsSourceSettings

Structs

AttributeName

Source parameters as described at https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html#API_ReceiveMessage_RequestParameters

MessageAttributeName

Message attribure names described at https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_ReceiveMessage.html#API_ReceiveMessage_RequestParameters

Interfaces

ISqsAckResult

Messages returned by a SqsAckFlow.

ISqsAckResultEntry

Messages returned by a SqsAckFlow.

ISqsResult

Result contained in a Sqs Response.