sqs FetchFromQueue FetchFromQueue

SQSMessageConsumer.cs

private async Task FetchFromQueue(){
        
    ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest();
    receiveMessageRequest.QueueUrl = _queueUrl;
    receiveMessageRequest.MaxNumberOfMessages = _maxNumberOfMessages;
    receiveMessageRequest.WaitTimeSeconds = _messageWaitTimeSeconds;
    ReceiveMessageResponse receiveMessageResponse = await _sqsClient.ReceiveMessageAsync(receiveMessageRequest, _token);    

    if (receiveMessageResponse.Messages.Count != 0)
    {                  
        for (int i = 0; i < receiveMessageResponse.Messages.Count; i++)
        { 
            string messageBody = receiveMessageResponse.Messages[i].Body;

            Console.WriteLine("Message Received: " + messageBody);

            await DeleteMessageAsync(receiveMessageResponse.Messages[i].ReceiptHandle);
        }
    }
    else{
        Console.WriteLine("No Messages to process"); 
    }                      
}