AmazonSQSProcessor

Processes messages from Amazon SQS queues for SimpleMessageBus.

Definition

Assembly: CloudNimble.SimpleMessageBus.Dispatch.Amazon.dll

Namespace: CloudNimble.SimpleMessageBus.Dispatch.Amazon

Inheritance: System.Object

Syntax

CloudNimble.SimpleMessageBus.Dispatch.Amazon.AmazonSQSProcessor

Summary

Processes messages from Amazon SQS queues for SimpleMessageBus.

Constructors

.ctor

Creates a new instance of the AmazonSQSProcessor.

Syntax

public AmazonSQSProcessor(CloudNimble.SimpleMessageBus.Dispatch.IMessageDispatcher dispatcher, Microsoft.Extensions.DependencyInjection.IServiceScopeFactory serviceScopeFactory)

Parameters

Name	Type	Description
dispatcher	CloudNimble.SimpleMessageBus.Dispatch.IMessageDispatcher	The IMessageDispatcher to use for processing messages.
serviceScopeFactory	Microsoft.Extensions.DependencyInjection.IServiceScopeFactory	The IServiceScopeFactory to use for creating service scopes.

Exceptions

Exception	Description
ArgumentNullException	dispatcher is null or
serviceScopeFactory is null.

.ctor Inherited

Inherited from object

Syntax

public Object()

Methods

Equals Inherited Virtual

Inherited from object

Syntax

public virtual bool Equals(object obj)

Parameters

Name	Type	Description
obj	object?	-

Returns

Type: bool

Equals Inherited

Inherited from object

Syntax

public static bool Equals(object objA, object objB)

Parameters

Name	Type	Description
objA	object?	-
objB	object?	-

Returns

Type: bool

GetHashCode Inherited Virtual

Inherited from object

Syntax

public virtual int GetHashCode()

Returns

Type: int

GetType Inherited

Inherited from object

Syntax

public System.Type GetType()

Returns

Type: System.Type

MemberwiseClone Inherited

Inherited from object

Syntax

protected internal object MemberwiseClone()

Returns

Type: object

ProcessQueue

Processes a message from the SQS queue.

Syntax

public System.Threading.Tasks.Task<Amazon.SQS.Model.Message> ProcessQueue(Amazon.SQS.Model.Message sqsMessage, Microsoft.Extensions.Logging.ILogger logger)

Parameters

Name	Type	Description
sqsMessage	Amazon.SQS.Model.Message	The SQS message to process.
logger	Microsoft.Extensions.Logging.ILogger	The logger instance.

Returns

Type: System.Threading.Tasks.Task<Amazon.SQS.Model.Message> A Task reference for the asynchronous function.

ReferenceEquals Inherited

Inherited from object

Syntax

public static bool ReferenceEquals(object objA, object objB)

Parameters

Name	Type	Description
objA	object?	-
objB	object?	-

Returns

Type: bool

ToString Inherited Virtual

Inherited from object

Syntax

public virtual string ToString()

Returns

Type: string?

Related APIs

• CloudNimble.SimpleMessageBus.Dispatch.IQueueProcessor