sqs SQSMessageConsumer Complete

SQSMessageConsumer.cs

public async Task Listen()
{                                               
    _isPolling = true;

    int i = 0;
    try{
        _source = new CancellationTokenSource();
        _token = _source.Token; 
        
        while(_isPolling){
            i++;
            Console.Write(i + ": ");
            await FetchFromQueue();
            Thread.Sleep(_delay);
        }                   
    }
    catch(TaskCanceledException ex){
        Console.WriteLine("Application Terminated: " + ex.Message); 
    }
    finally{
        _source.Dispose();
    }                
}