Interface IQueueStorageProvider

Namespace: CrashCABN.DataAccess.Queues
Assembly: CrashCABN.DataAccess.Queues.Abstractions.dll
Syntax
public interface IQueueStorageProvider

Methods

View Source

PopAsync(string, IQueueMessage, CancellationToken)

Declaration
Task PopAsync(string queueName, IQueueMessage message, CancellationToken ct = default)
Parameters
Type Name Description
string queueName
IQueueMessage message
CancellationToken ct
Returns
Type Description
Task
View Source

PullAsync<T>(string, CancellationToken)

Declaration
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
View Source

PushAsync(string, object, CancellationToken)

Declaration
ValueTask PushAsync(string queueName, object message, CancellationToken ct = default)
Parameters
Type Name Description
string queueName
object message
CancellationToken ct
Returns
Type Description
ValueTask