Dev

.github/dependabot.yml

@@ -6,8 +6,8 @@ updates:
   - package-ecosystem: "github-actions"
     directory: "/"
     schedule:
-      # Check for updates to GitHub Actions every week
-      interval: "weekly"
+      # Check for updates to GitHub Actions every quarter
+      interval: "quarterly"
     labels:
       - "Release Not Needed"
-    target-branch: "dev"
+    target-branch: "dev"

.github/workflows/handle-stale-discussions.yml

@@ -13,6 +13,6 @@ jobs:
       discussions: write
     steps:
       - name: Stale discussions action
-        uses: aws-github-ops/handle-stale-discussions@711a9813957be17629fc6933afcd8bd132c57254 #v1.6
+        uses: aws-github-ops/handle-stale-discussions@c0beee451a5d33d9c8f048a6d4e7c856b5422544 #v1.6.0
         env:
           GITHUB_TOKEN:  ${{secrets.GITHUB_TOKEN}}

.github/workflows/semgrep-analysis.yml

@@ -35,7 +35,7 @@ jobs:
             p/owasp-top-ten
 
       - name: Upload SARIF file for GitHub Advanced Security Dashboard
-        uses: github/codeql-action/upload-sarif@60168efe1c415ce0f5521ea06d5c2062adbeed1b #v3.28.17
+        uses: github/codeql-action/upload-sarif@fca7ace96b7d713c7035871441bd52efbe39e27e #v3.28.19
         with:
           sarif_file: semgrep.sarif
         if: always()

test/AWS.Messaging.UnitTests/SQSMessagePollerTests.cs

@@ -78,8 +78,11 @@ public async Task SQSMessagePoller_PollingControlStopped_DoesNotPollSQS()
     public async Task SQSMessagePoller_PollingControlRestarted_PollsSQS()
     {
         var client = new Mock<IAmazonSQS>();
+        var messageReceived = new TaskCompletionSource<bool>();
         client.Setup(x => x.ReceiveMessageAsync(It.IsAny<ReceiveMessageRequest>(), It.IsAny<CancellationToken>()))
-            .ReturnsAsync(new ReceiveMessageResponse(), TimeSpan.FromMilliseconds(50));
+            .ReturnsAsync(new ReceiveMessageResponse(), TimeSpan.FromMilliseconds(50))
+            .Callback(() => messageReceived.TrySetResult(true));
+
         var pollingControlToken = new PollingControlToken
         {
             PollingWaitTime = TimeSpan.FromMilliseconds(25)
@@ -90,12 +93,24 @@ public async Task SQSMessagePoller_PollingControlRestarted_PollsSQS()
         var pump = BuildMessagePumpService(client, options => { options.WaitTimeSeconds = 1; }, pollingControlToken: pollingControlToken);
         var task = pump.StartAsync(source.Token);
 
+        // Verify no messages are received while polling is stopped
         client.Verify(x => x.ReceiveMessageAsync(It.IsAny<ReceiveMessageRequest>(), It.IsAny<CancellationToken>()), Times.Never);
 
+        // Start polling and wait for a message to be received
         pollingControlToken.StartPolling();
+
+        // Wait for a message to be received with a timeout
+        using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5));
+        try 
+        {
+            await messageReceived.Task.WaitAsync(cts.Token);
+        }
+        catch (OperationCanceledException)
+        {
+            Assert.Fail("Timed out waiting for message to be received after polling was restarted");
+        }
 
-        SpinWait.SpinUntil(() => false, pollingControlToken.PollingWaitTime * 5);
-
+        // Verify that messages were received
         client.Verify(x => x.ReceiveMessageAsync(It.IsAny<ReceiveMessageRequest>(), It.IsAny<CancellationToken>()), Times.AtLeastOnce());
 
         source.Cancel();