Fixed prefetchcount being applied to the incorrect channel
This commit is contained in:
parent
847e6a6d83
commit
017c4c130f
@ -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) =>
|
||||
{
|
||||
|
Loading…
Reference in New Issue
Block a user