Skip to content

Commit b2975b0

Browse files
committed
Fix use of Enqueue return value in two places.
1 parent be1d1e3 commit b2975b0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

projects/RabbitMQ.Client/Impl/ChannelBase.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1632,7 +1632,7 @@ await _rpcSemaphore.WaitAsync(k.CancellationToken)
16321632
.ConfigureAwait(false);
16331633
try
16341634
{
1635-
Enqueue(k);
1635+
enqueued = Enqueue(k);
16361636

16371637
var method = new QueueUnbind(queue, exchange, routingKey, arguments);
16381638
await ModelSendAsync(in method, k.CancellationToken)
@@ -1719,7 +1719,7 @@ await _rpcSemaphore.WaitAsync(k.CancellationToken)
17191719
.ConfigureAwait(false);
17201720
try
17211721
{
1722-
Enqueue(k);
1722+
enqueued = Enqueue(k);
17231723

17241724
var method = new TxSelect();
17251725
await ModelSendAsync(in method, k.CancellationToken)

0 commit comments

Comments
 (0)