Updates AWS SDK dependencies

Updates the AWS SDK dependencies to the latest versions.

Refactors the SQS queue worker loop to use a cancellation token
source for improved resource management and thread cleanup.

Author: niemyjski

src/Foundatio.AWS/Foundatio.AWS.csproj

@@ -4,9 +4,9 @@
     <PackageTags>$(PackageTags);Amazon;AWS;S3</PackageTags>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="AWSSDK.CloudWatch" Version="4.0.6.2" />
-    <PackageReference Include="AWSSDK.S3" Version="4.0.16.1" />
-    <PackageReference Include="AWSSDK.SQS" Version="4.0.2.9" />
+    <PackageReference Include="AWSSDK.CloudWatch" Version="4.0.6.4" />
+    <PackageReference Include="AWSSDK.S3" Version="4.0.17" />
+    <PackageReference Include="AWSSDK.SQS" Version="4.0.2.11" />
 
     <PackageReference Include="Foundatio" Version="12.0.1-preview.0.39" Condition="'$(ReferenceFoundatioSource)' == '' OR '$(ReferenceFoundatioSource)' == 'false'" />
     <ProjectReference Include="..\..\..\Foundatio\src\Foundatio\Foundatio.csproj" Condition="'$(ReferenceFoundatioSource)' == 'true'" />

src/Foundatio.AWS/Queues/SQSQueue.cs

@@ -373,44 +373,44 @@ protected override void StartWorkingImpl(Func<IQueueEntry<T>, CancellationToken,
         if (handler == null)
             throw new ArgumentNullException(nameof(handler));
 
-        var linkedCancellationToken = GetLinkedDisposableCancellationTokenSource(cancellationToken);
+        var linkedCancellationTokenSource = GetLinkedDisposableCancellationTokenSource(cancellationToken);
 
         Task.Run(async () =>
         {
             _logger.LogTrace("WorkerLoop Start {QueueName}", _options.Name);
 
-            while (!linkedCancellationToken.IsCancellationRequested)
+            while (!linkedCancellationTokenSource.IsCancellationRequested)
             {
                 _logger.LogTrace("WorkerLoop Signaled {QueueName}", _options.Name);
 
                 IQueueEntry<T> entry = null;
                 try
                 {
-                    entry = await DequeueImplAsync(linkedCancellationToken.Token).AnyContext();
+                    entry = await DequeueImplAsync(linkedCancellationTokenSource.Token).AnyContext();
                 }
                 catch (OperationCanceledException) { }
 
-                if (linkedCancellationToken.IsCancellationRequested || entry == null)
+                if (linkedCancellationTokenSource.IsCancellationRequested || entry == null)
                     continue;
 
                 try
                 {
-                    await handler(entry, linkedCancellationToken.Token).AnyContext();
-                    if (autoComplete && !entry.IsAbandoned && !entry.IsCompleted && !linkedCancellationToken.IsCancellationRequested)
+                    await handler(entry, linkedCancellationTokenSource.Token).AnyContext();
+                    if (autoComplete && !entry.IsAbandoned && !entry.IsCompleted && !linkedCancellationTokenSource.IsCancellationRequested)
                         await entry.CompleteAsync().AnyContext();
                 }
                 catch (Exception ex)
                 {
                     Interlocked.Increment(ref _workerErrorCount);
                     _logger.LogError(ex, "Worker error: {Message}", ex.Message);
 
-                    if (!entry.IsAbandoned && !entry.IsCompleted && !linkedCancellationToken.IsCancellationRequested)
+                    if (!entry.IsAbandoned && !entry.IsCompleted && !linkedCancellationTokenSource.IsCancellationRequested)
                         await entry.AbandonAsync().AnyContext();
                 }
             }
 
-            _logger.LogTrace("Worker exiting: {QueueName} IsCancellationRequested={IsCancellationRequested}", _options.Name, linkedCancellationToken.IsCancellationRequested);
-        }, linkedCancellationToken.Token).ContinueWith(_ => linkedCancellationToken.Dispose());
+            _logger.LogTrace("Worker exiting: {QueueName} IsCancellationRequested={IsCancellationRequested}", _options.Name, linkedCancellationTokenSource.IsCancellationRequested);
+        }, linkedCancellationTokenSource.Token).ContinueWith(_ => linkedCancellationTokenSource.Dispose());
     }
 
     public override void Dispose()