diff --git a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs index f1b75c191..979b0285e 100644 --- a/projects/RabbitMQ.Client/client/impl/ChannelBase.cs +++ b/projects/RabbitMQ.Client/client/impl/ChannelBase.cs @@ -453,7 +453,7 @@ protected ValueTask ModelSendAsync(in TMethod method, in THead { if (!_flowControlBlock.IsSet) { - _flowControlBlock.Wait(); + _flowControlBlock.Wait(cancellationToken); } return Session.TransmitAsync(in method, in header, body, cancellationToken);