AmazonSQS - improve tests

Signed-off-by: Tomasz Maruszak <maruszaktomasz@gmail.com>

Author: zarusz

src/Host.Plugin.Properties.xml

@@ -4,7 +4,7 @@
   <Import Project="Common.NuGet.Properties.xml" />
 
   <PropertyGroup>
-    <Version>3.0.1</Version>
+    <Version>3.0.2</Version>
   </PropertyGroup>
 
 </Project>

src/Tests/SlimMessageBus.Host.AmazonSQS.Test/SqsMessageBusIt.cs

@@ -49,10 +49,17 @@ void AdditionalSqsSetup(SqsMessageBusSettings cfg)
                 var r = await client.ListQueuesAsync(QueueNamePrefix);
                 foreach (var queueUrl in r.QueueUrls)
                 {
-                    var tagsResponse = await client.ListQueueTagsAsync(new ListQueueTagsRequest { QueueUrl = queueUrl });
-                    if (!tagsResponse.Tags.TryGetValue(CreatedDateTag, out var createdDateTag) || createdDateTag != today)
+                    try
                     {
-                        await client.DeleteQueueAsync(queueUrl);
+                        var tagsResponse = await client.ListQueueTagsAsync(new ListQueueTagsRequest { QueueUrl = queueUrl });
+                        if (!tagsResponse.Tags.TryGetValue(CreatedDateTag, out var createdDateTag) || createdDateTag != today)
+                        {
+                            await client.DeleteQueueAsync(queueUrl);
+                        }
+                    }
+                    catch (QueueDoesNotExistException)
+                    {
+                        // ignore, other tests might already have deleted the queue
                     }
                 }
                 await provision();

src/Tests/SlimMessageBus.Host.Test/MessageBusBaseTests.cs

@@ -638,15 +638,17 @@ public async Task When_Start_Given_ConcurrentCalls_Then_ItOnlyStartsConsumersOnc
         // trigger lazy bus creation here ahead of the Tasks
         var bus = Bus;
 
+        await bus.Start();
+
         // act
         for (var i = 0; i < 10; i++)
         {
-            await Task.WhenAll(Enumerable.Range(0, 1000).Select(x => bus.Start()).ToList());
+            await Task.WhenAll(Enumerable.Range(0, 10000).Select(x => bus.Start()).AsParallel());
         }
 
         // assert
-        bus._startedCount.Should().Be(1);
         bus._stoppedCount.Should().Be(0);
+        bus._startedCount.Should().Be(1);
     }
 
     [Fact]
@@ -668,8 +670,8 @@ public async Task When_Stop_Given_ConcurrentCalls_Then_ItOnlyStopsConsumersOnce(
         }
 
         // assert
-        bus._startedCount.Should().Be(1);
         bus._stoppedCount.Should().Be(1);
+        bus._startedCount.Should().Be(1);
     }
 
     public class ProduceResponseTests