From 017c4c130f0a992f1c3c1fb5a92edfeba4161c07 Mon Sep 17 00:00:00 2001 From: Mark van Renswoude Date: Tue, 26 Oct 2021 13:29:48 +0200 Subject: [PATCH] Fixed prefetchcount being applied to the incorrect channel --- Tapeti/Connection/TapetiClient.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Tapeti/Connection/TapetiClient.cs b/Tapeti/Connection/TapetiClient.cs index fba46b8..9f68728 100644 --- a/Tapeti/Connection/TapetiClient.cs +++ b/Tapeti/Connection/TapetiClient.cs @@ -820,7 +820,7 @@ namespace Tapeti.Connection } if (connectionParams.PrefetchCount > 0) - capturedPublishChannelModel.BasicQos(0, connectionParams.PrefetchCount, false); + capturedConsumeChannelModel.BasicQos(0, connectionParams.PrefetchCount, false); capturedPublishChannelModel.ModelShutdown += (_, e) => {