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) => {