Class AzureQueueProvider

Inheritance

object

AzureQueueProviderBase

AzureQueueProvider

Implements

IEquatable<AzureQueueProviderBase>

IQueueStorageProvider

IEquatable<AzureQueueProvider>

Inherited Members

AzureQueueProviderBase.ClientFactory

AzureQueueProviderBase.HandleError(string, Response)

AzureQueueProviderBase.PushInternalAsync(QueueClient, object, CancellationToken)

AzureQueueProviderBase.GetQueueClientForAccount(string, string)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: CrashCABN.DataAccess.Queues

Assembly: CrashCABN.DataAccess.Queues.dll

Syntax

public record AzureQueueProvider : AzureQueueProviderBase, IEquatable<AzureQueueProviderBase>, IQueueStorageProvider, IEquatable<AzureQueueProvider>

Constructors

AzureQueueProvider(QueueClientFactory, IOptions<QueueDataAccessOptions>)

Declaration

public AzureQueueProvider(QueueClientFactory ClientFactory, IOptions<QueueDataAccessOptions> DataAccessOptions)

Parameters

Type	Name	Description
QueueClientFactory	ClientFactory
IOptions<QueueDataAccessOptions>	DataAccessOptions

Properties

DataAccessOptions

Declaration

public IOptions<QueueDataAccessOptions> DataAccessOptions { get; init; }

Property Value

Type	Description
IOptions<QueueDataAccessOptions>

Methods

PopAsync(string, IQueueMessage, CancellationToken)

Declaration

public Task PopAsync(string queueName, IQueueMessage message, CancellationToken ct = default)

Parameters

Type	Name	Description
string	queueName
IQueueMessage	message
CancellationToken	ct

Returns

Type	Description
Task

PullAsync<T>(string, CancellationToken)

Declaration

public IAsyncEnumerable<QueueMessage<T>> PullAsync<T>(string queueName, CancellationToken ct = default)

Parameters

Type	Name	Description
string	queueName
CancellationToken	ct

Returns

Type	Description
IAsyncEnumerable<QueueMessage<T>>

Type Parameters

Name	Description
T

PushAsync(string, object, CancellationToken)

Declaration

public ValueTask PushAsync(string queueName, object message, CancellationToken ct = default)

Parameters

Type	Name	Description
string	queueName
object	message
CancellationToken	ct

Returns

Type	Description
ValueTask

Implements

IEquatable<T>

IQueueStorageProvider

IEquatable<T>