Class SqsSource

API to create SQS sources.

Inheritance

Object

SqsSource

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 SqsSource

Methods

Create(IAmazonSQS, String, SqsSourceSettings)

Declaration

public static Source<Message, NotUsed> Create(IAmazonSQS client, string queueUrl, SqsSourceSettings settings = null)

Parameters

Type	Name	Description
Amazon.SQS.IAmazonSQS	client
String	queueUrl
SqsSourceSettings	settings

Returns

Type	Description
Akka.Streams.Dsl.Source<Amazon.SQS.Model.Message, Akka.NotUsed>