From 8b11ed7827de8ac5129177149dae611cb87be22f Mon Sep 17 00:00:00 2001 From: Jo Palac Date: Fri, 20 Dec 2024 10:40:31 +1000 Subject: [PATCH 1/2] Update deliveryAttempts and failedBasicAckMessages to 1000 --- src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs b/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs index 5dde3fcf7..fa6f78c9a 100644 --- a/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs +++ b/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs @@ -28,8 +28,8 @@ sealed class MessagePump : IMessageReceiver, IDisposable readonly Action criticalErrorAction; readonly TimeSpan retryDelay; readonly string name; - readonly FastConcurrentLru deliveryAttempts = new(100); - readonly FastConcurrentLru failedBasicAckMessages = new(100); + readonly FastConcurrentLru deliveryAttempts = new(1_000); + readonly FastConcurrentLru failedBasicAckMessages = new(1_000); bool disposed; OnMessage onMessage; From 2106d8b5416abd7b7cb1353f037dfd2eb8b2bbb5 Mon Sep 17 00:00:00 2001 From: Jo Palac Date: Fri, 20 Dec 2024 15:28:18 +1000 Subject: [PATCH 2/2] change to kickoff build again --- src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs b/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs index fa6f78c9a..73e19b74a 100644 --- a/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs +++ b/src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs @@ -531,4 +531,4 @@ public void Dispose() disposed = true; } } -} +} \ No newline at end of file