File tree Expand file tree Collapse file tree 3 files changed +12
-5
lines changed
SlimMessageBus.Host.AmazonSQS.Test Expand file tree Collapse file tree 3 files changed +12
-5
lines changed Original file line number Diff line number Diff line change 44 <Import Project =" Common.NuGet.Properties.xml" />
55
66 <PropertyGroup >
7- <Version >3.0.1 </Version >
7+ <Version >3.0.2 </Version >
88 </PropertyGroup >
99
1010</Project >
Original file line number Diff line number Diff line change @@ -49,10 +49,17 @@ void AdditionalSqsSetup(SqsMessageBusSettings cfg)
4949 var r = await client . ListQueuesAsync ( QueueNamePrefix ) ;
5050 foreach ( var queueUrl in r . QueueUrls )
5151 {
52- var tagsResponse = await client . ListQueueTagsAsync ( new ListQueueTagsRequest { QueueUrl = queueUrl } ) ;
53- if ( ! tagsResponse . Tags . TryGetValue ( CreatedDateTag , out var createdDateTag ) || createdDateTag != today )
52+ try
5453 {
55- await client . DeleteQueueAsync ( queueUrl ) ;
54+ var tagsResponse = await client . ListQueueTagsAsync ( new ListQueueTagsRequest { QueueUrl = queueUrl } ) ;
55+ if ( ! tagsResponse . Tags . TryGetValue ( CreatedDateTag , out var createdDateTag ) || createdDateTag != today )
56+ {
57+ await client . DeleteQueueAsync ( queueUrl ) ;
58+ }
59+ }
60+ catch ( QueueDoesNotExistException )
61+ {
62+ // ignore, other tests might already have deleted the queue
5663 }
5764 }
5865 await provision ( ) ;
Original file line number Diff line number Diff line change @@ -641,7 +641,7 @@ public async Task When_Start_Given_ConcurrentCalls_Then_ItOnlyStartsConsumersOnc
641641 // act
642642 for ( var i = 0 ; i < 10 ; i ++ )
643643 {
644- await Task . WhenAll ( Enumerable . Range ( 0 , 1000 ) . Select ( x => bus . Start ( ) ) . ToList ( ) ) ;
644+ await Task . WhenAll ( Enumerable . Range ( 0 , 10000 ) . Select ( x => bus . Start ( ) ) . AsParallel ( ) ) ;
645645 }
646646
647647 // assert
You can’t perform that action at this time.
0 commit comments