fixing warnings

Signed-off-by: Neil South <[email protected]>

Author: neildsouth

src/Api/Storage/FileStorageMetadata.cs

@@ -117,6 +117,6 @@ public virtual void SetFailed()
             File.SetFailed();
         }
 
-        public string PayloadId { get; set; }
+        public string? PayloadId { get; set; }
     }
 }

src/Database/EntityFramework/Test/SourceApplicationEntityRepositoryTest.cs

@@ -119,6 +119,7 @@ public async Task GivenAAETitleName_WhenFindByAETAsyncIsCalled_ExpectItToReturnM
             Assert.Equal("AET1", actual.FirstOrDefault()!.Name);
 
             actual = await store.FindByAETAsync("AET6").ConfigureAwait(false);
+            Assert.NotNull(actual);
             Assert.Empty(actual);
         }
 

src/Database/MongoDB/Integration.Test/SourceApplicationEntityRepositoryTest.cs

@@ -124,6 +124,7 @@ public async Task GivenAETitle_WhenFindByAETitleAsyncIsCalled_ExpectItToReturnMa
             Assert.Equal("AET1", actual.FirstOrDefault()!.Name);
 
             actual = await store.FindByAETAsync("AET6").ConfigureAwait(false);
+            Assert.NotNull(actual);
             Assert.Empty(actual);
         }
 

tests/Integration.Test/Drivers/RabbitMqConsumer.cs

@@ -45,10 +45,10 @@ public RabbitMqConsumer(RabbitMQMessageSubscriberService subscriberService, stri
             _outputHelper = outputHelper ?? throw new ArgumentNullException(nameof(outputHelper));
             _messages = new ConcurrentBag<Message>();
 
-            subscriberService.Subscribe(
+            subscriberService.SubscribeAsync(
                 queueName,
                 queueName,
-                (eventArgs) =>
+                async (eventArgs) =>
                 {
                     _outputHelper.WriteLine($"Message received from queue {queueName} for {queueName}.");
                     _messages.Add(eventArgs.Message);