AzureQueueStreamProviderUtils Methods

Utility functions for azure queue Persistent stream provider.

ClearAllUsedAzureQueues(ILoggerFactory, List<string>, AzureQueueOptions)

static

public static Task ClearAllUsedAzureQueues(ILoggerFactory loggerFactory, List<string> azureQueueNames, AzureQueueOptions queueOptions)

Helper method for testing. Clears all messages in all the queues used by the specified stream provider.

loggerFactoryILoggerFactory: logger factory to use
azureQueueNamesList<string>: The deployment ID hosting the stream provider.
queueOptionsAzureQueueOptions: The azure storage options.

static

public static Task ClearAllUsedAzureQueues(ILoggerFactory loggerFactory, List<string> azureQueueNames, string storageConnectionString)

Helper method for testing. Clears all messages in all the queues used by the specified stream provider.

loggerFactoryILoggerFactory: logger factory to use
azureQueueNamesList<string>: The deployment ID hosting the stream provider.
storageConnectionStringstring: The azure storage connection string.

static

public static Task DeleteAllUsedAzureQueues(ILoggerFactory loggerFactory, List<string> azureQueueNames, AzureQueueOptions queueOptions)

Helper method for testing. Deletes all the queues used by the specified stream provider.

static

public static Task DeleteAllUsedAzureQueues(ILoggerFactory loggerFactory, List<string> azureQueueNames, string storageConnectionString)

Helper method for testing. Deletes all the queues used by the specified stream provider.

static

public static List<string> GenerateDefaultAzureQueueNames(string serviceId, string providerName)

Generate default azure queue names