Class LambdaQueueFunctionDependencyProvider
The Lambda
Inherited Members
Namespace: LambdaSharp.SimpleQueueService
Assembly: LambdaSharp.SimpleQueueService.dll
Syntax
public class LambdaQueueFunctionDependencyProvider : LambdaFunctionDependencyProvider, ILambdaQueueFunctionDependencyProvider, ILambdaFunctionDependencyProvider
Constructors
LambdaQueueFunctionDependencyProvider(Func<DateTime>, Action<String>, ILambdaConfigSource, IAmazonKeyManagementService, IAmazonSQS)
Creates new instance of Lambda
Declaration
public LambdaQueueFunctionDependencyProvider(Func<DateTime> utcNowCallback = null, Action<string> logCallback = null, ILambdaConfigSource configSource = null, IAmazonKeyManagementService kmsClient = null, IAmazonSQS sqsClient = null)
Parameters
Type | Name | Description |
---|---|---|
System. |
utcNowCallback | A function that return the current |
System. |
logCallback | An action that logs a string message. Defaults to Amazon. |
ILambda |
configSource | A ILambda |
Amazon. |
kmsClient | A Amazon. |
Amazon. |
sqsClient | A Amazon. |
Methods
DeleteMessagesFromQueueAsync(String, IEnumerable<(String MessageId, String ReceiptHandle)>)
Delete a batch of message from an SQS queue. The Lambda function requires sqs:DeleteMessageBatch
permission
on the specified SQS URL.
Declaration
public Task DeleteMessagesFromQueueAsync(string queueArn, IEnumerable<(string MessageId, string ReceiptHandle)> messages)
Parameters
Type | Name | Description |
---|---|---|
System. |
queueArn | SQS ARN. |
System. |
messages | Enumeration of |
Returns
Type | Description |
---|---|
System. |
The task object representing the asynchronous operation. |
GetMaxRetriesForQueueAsync(String)
Determine how many times a message should be retried for a given SQS queue.
Declaration
public async Task<int> GetMaxRetriesForQueueAsync(string queueArn)
Parameters
Type | Name | Description |
---|---|---|
System. |
queueArn | SQS ARN. |
Returns
Type | Description |
---|---|
System. |
The task object representing the asynchronous operation. |