Fix use of Enqueue return value in two places.

ngbrown · Oct 1, 2024 · b2975b0 · b2975b0
1 parent be1d1e3
commit b2975b0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/projects/RabbitMQ.Client/Impl/ChannelBase.cs b/projects/RabbitMQ.Client/Impl/ChannelBase.cs
@@ -1632,7 +1632,7 @@ await _rpcSemaphore.WaitAsync(k.CancellationToken)
                 .ConfigureAwait(false);
             try
             {
-                Enqueue(k);
+                enqueued = Enqueue(k);
 
                 var method = new QueueUnbind(queue, exchange, routingKey, arguments);
                 await ModelSendAsync(in method, k.CancellationToken)
@@ -1719,7 +1719,7 @@ await _rpcSemaphore.WaitAsync(k.CancellationToken)
                 .ConfigureAwait(false);
             try
             {
-                Enqueue(k);
+                enqueued = Enqueue(k);
 
                 var method = new TxSelect();
                 await ModelSendAsync(in method, k.CancellationToken)