Fix analyzer warnings: use indexers and rename TestDoubles to Messages

Author: ANcpLua

….Paperless.RabbitMq.Tests/TestDoubles.cs …EN3.Paperless.RabbitMq.Tests/Messages.csSWEN3.Paperless.RabbitMq.Tests/TestDoubles.cs renamed to SWEN3.Paperless.RabbitMq.Tests/Messages.cs SWEN3.Paperless.RabbitMq.Tests/TestDoubles.cs renamed to SWEN3.Paperless.RabbitMq.Tests/Messages.cs

@@ -37,6 +37,24 @@ public async Task CreateConsumerAsync_ShouldDeriveQueueNameFromType()
         GetQueueName(consumer).Should().Be("SimpleMessageQueue");
     }
 
+    [Fact]
+    public async Task CreateConsumerAsync_ShouldForwardCancellationTokens()
+    {
+        var connectionShutdown = new ShutdownEventArgs(ShutdownInitiator.Application, 200, "closing");
+        var channelShutdown = new ShutdownEventArgs(ShutdownInitiator.Application, 200, "channel closing");
+        _connectionMock.Setup(c => c.CloseReason).Returns(connectionShutdown);
+        _channelMock.Setup(c => c.CloseReason).Returns(channelShutdown);
+        _connectionMock.Setup(c => c.CreateChannelAsync(options: null, connectionShutdown.CancellationToken))
+            .ReturnsAsync(_channelMock.Object);
+        _channelMock.Setup(c => c.BasicQosAsync(0, 1, false, channelShutdown.CancellationToken))
+            .Returns(Task.CompletedTask);
+
+        await using var _ = await _factory.CreateConsumerAsync<Messages.SimpleMessage>();
+
+        _connectionMock.Verify(c => c.CreateChannelAsync(options: null, connectionShutdown.CancellationToken), Times.Once);
+        _channelMock.Verify(c => c.BasicQosAsync(0, 1, false, channelShutdown.CancellationToken), Times.Once);
+    }
+
     private static string GetQueueName(RabbitMqConsumer<Messages.SimpleMessage> consumer) =>
         (string)typeof(RabbitMqConsumer<Messages.SimpleMessage>)
             .GetField("_queueName", System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Instance)!

SWEN3.Paperless.RabbitMq.Tests/Unit/RabbitMqConsumerFactoryTests.cs

@@ -69,19 +69,19 @@ public async Task Publish_WhenClientIsSlow_ShouldDropOldestMessages()
 
         // Assert: Read all available messages
         var receivedMessages = new List<Messages.SimpleMessage>();
-        
+
         // Read until empty (try-read pattern is safer than assuming exact count due to concurrency)
         while (reader.TryRead(out var msg))
         {
             receivedMessages.Add(msg);
         }
 
         // Since it's a bounded channel, reader might not be empty immediately if we were reading in parallel,
-        // but here we are single-threaded in test. 
+        // but here we are single-threaded in test.
         // However, strictly speaking, TryRead returns what's currently available.
-        
+
         receivedMessages.Should().HaveCount(100); // Should match capacity
-        receivedMessages.First().Id.Should().Be(expectedFirstMessageId); // Should start from 11
-        receivedMessages.Last().Id.Should().Be(messagesToSend); // Should end at 110
+        receivedMessages[0].Id.Should().Be(expectedFirstMessageId); // Should start from 11
+        receivedMessages[^1].Id.Should().Be(messagesToSend); // Should end at 110
     }
 }