Skip to content

Commit

Permalink
* Remove a lot of unused code
Browse files Browse the repository at this point in the history
  • Loading branch information
lukebakken committed Mar 21, 2024
1 parent e5cd1a0 commit f664259
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 354 deletions.
8 changes: 5 additions & 3 deletions projects/RabbitMQ.Client/client/impl/AutorecoveringChannel.cs
Expand Up @@ -248,11 +248,13 @@ public void Dispose()
public ValueTask BasicAckAsync(ulong deliveryTag, bool multiple)
=> InnerChannel.BasicAckAsync(deliveryTag, multiple);

public Task BasicCancelAsync(string consumerTag, bool noWait)
public async Task BasicCancelAsync(string consumerTag, bool noWait)
{
ThrowIfDisposed();
_connection.DeleteRecordedConsumer(consumerTag, recordedEntitiesSemaphoreHeld: false);
return _innerChannel.BasicCancelAsync(consumerTag, noWait);
await _connection.DeleteRecordedConsumerAsync(consumerTag, recordedEntitiesSemaphoreHeld: false)
.ConfigureAwait(false);
await _innerChannel.BasicCancelAsync(consumerTag, noWait)
.ConfigureAwait(false);
}

public async Task<string> BasicConsumeAsync(string queue, bool autoAck, string consumerTag, bool noLocal, bool exclusive,
Expand Down

0 comments on commit f664259

Please sign in to comment.