The method PurgeInputQueue() for AzureStorageQueuesTransport is broken.
The current code is:
...
var queue = GetQueue(Address);
if (await queue.ExistsAsync()) return;
...
await queue.ClearAsync(ExponentialRetryRequestOptions, new OperationContext());
...
Which causes the following behavior
If the queue doesn't exist, the application attempts to Clear the queue, which results in an exception
If the queue does exist, the application exits the method and doesn't purge the queue
The method
PurgeInputQueue()
forAzureStorageQueuesTransport
is broken.The current code is:
Which causes the following behavior