-
Notifications
You must be signed in to change notification settings - Fork 580
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Part of the fix for #1472 * Remove synchronous API methods * Update all usages of `CreateConnection` to use `CreateConnectionAsync` * Ensure that all connections and channels are closed prior to `Dispose` * Use lowest feasible `LangVersion` for projects * Add note about nullable reference types in `RabbitMQ.Client.csproj` * Convert `ManualResetEventSlim` and associated classes to `TaskCompletionSource<bool>` or `SemaphoreSlim` * Only use `ValueTask` for operations that need the performance benefit * Add async passive declaration convenience methods to the async API * Fix missing `CloseAsync` statements prior to disposing `IConnection` and `IChannel` instances * Fix bug where `QueueBindAsync` did not record the binding in an `AutorecoveringChannel` * Added `ProcessUtil` to run command line executables via `async` * Make `TopologyRecoveryExceptionHandler` async * Ensure test classes call `base.DisposeAsync()` appropriately * Add `RABBITMQ_LONG_RUNNING_TESTS=true` to `build.ps1` * Remove `Close` and `Abort` from `IConnection` and `IConnectionExtensions` * Remove `Close` and `Abort` from `IChannel` and `IChannelExtensions` * Remove use of `RecoveryChannelFactory` * Remove `Close` from `AutorecoveringConnection` and `Connection` * Ensure `TestConnectionRecoveryWithoutSetup` tests close and dispose of channels correctly * Remove `ConfirmSelect` * Remove `ExchangeBind` and `ExchangeBindNoWait` * Add `noWait` to `ExchangeBindAsync` and `ExchangeDeclareAsync` * Remove `ExchangeDeclarePassive` * Fix stack overflow in `ExchangeBindAsync` * Remove `ExchangeDelete` and `ExchangeDeleteNoWait` * Remove `BasicGet` * Remove `BasicNack` * Change `BasicNackAsync` to return `ValueTask` * Remove `BasicCancel` and `BasicCancelNoWait` * Remove `BasicPublish` * Remove `BasicQos` * Remove `BasicReject` * Remove `ExchangeUnbind` and `ExchangeUnbindNoWait` * Remove `QueueBind`, `QueueBindNoWait`, QueueDeclare`, `QueueDeclareNoWait`, and `QueueDeclarePassive` * Remove `QueueDelete` and `QueueDeleteNoWait` * Make `noWait` the last param in the arg list. Default is `false` * Remove `BasicAck` * Modify `IBasicConsumer` to make `HandleBasicDeliver` an async method * Move `passive` to the end of the argument list, just before `noWait` * Remove `QueuePurge` * Remove `QueueUnbind` * Remove `TxSelect`, `TxCommit` and `TxRollback` * Remove `WaitForConfirms` and `WaitForConfirmsOrDie` * Remove `BasicConsume` * Delete code for sync API
- Loading branch information
1 parent
f8a3028
commit 0cab550
Showing
107 changed files
with
3,284 additions
and
4,208 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.