* Fix test failures due to not passing _consumerDispatchConcurrency…

… correctly to `CreateChannelOptions`
rabbitmq · Oct 23, 2024 · f28310a · f28310a
1 parent cffe0fd
commit f28310a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/projects/Test/Common/IntegrationFixture.cs b/projects/Test/Common/IntegrationFixture.cs
@@ -64,10 +64,10 @@ public abstract class IntegrationFixture : IAsyncLifetime
 
         protected ConnectionFactory _connFactory;
         protected IConnection _conn;
-        protected IChannel _channel;
 
-        protected static readonly CreateChannelOptions _createChannelOptions = new(publisherConfirmationsEnabled: true,
+        protected CreateChannelOptions _createChannelOptions = new(publisherConfirmationsEnabled: true,
             publisherConfirmationTrackingEnabled: true);
+        protected IChannel _channel;
 
         protected static readonly Encoding _encoding = new UTF8Encoding();
         protected static readonly int _processorCount = Environment.ProcessorCount;
@@ -156,6 +156,8 @@ public virtual async Task InitializeAsync()
 
                 if (_openChannel)
                 {
+                    _createChannelOptions = new CreateChannelOptions(publisherConfirmationsEnabled: true,
+                        publisherConfirmationTrackingEnabled: true, consumerDispatchConcurrency: _consumerDispatchConcurrency);
                     _channel = await _conn.CreateChannelAsync(_createChannelOptions);
                 }
 

diff --git a/projects/Test/Common/TestConnectionRecoveryBase.cs b/projects/Test/Common/TestConnectionRecoveryBase.cs
@@ -340,7 +340,7 @@ public virtual Task PostHandleDeliveryAsync(ulong deliveryTag,
             }
         }
 
-        protected static async Task<bool> SendAndConsumeMessageAsync(IConnection conn, string queue, string exchange, string routingKey)
+        protected async Task<bool> SendAndConsumeMessageAsync(IConnection conn, string queue, string exchange, string routingKey)
         {
             using (IChannel ch = await conn.CreateChannelAsync(_createChannelOptions))
             {