Foundatio by ejsmith, bniemyjski

<PackageReference Include="Foundatio" Version="3.0.532" />

.NET API 211,968 bytes

IQueue<T>

public interface IQueue<T> : IHaveSerializer, IDisposable

AsyncEvent<AbandonedEventArgs<T>> Abandoned { get; }

AsyncEvent<CompletedEventArgs<T>> Completed { get; }

AsyncEvent<DequeuedEventArgs<T>> Dequeued { get; }

AsyncEvent<EnqueuedEventArgs<T>> Enqueued { get; }

AsyncEvent<EnqueuingEventArgs<T>> Enqueuing { get; }

string QueueId { get; }

Task AbandonAsync(string id)

void AttachBehavior(IQueueBehavior<T> behavior)

Task CompleteAsync(string id)

Task DeleteQueueAsync()

Task<QueueEntry<T>> DequeueAsync(CancellationToken cancellationToken = default)

Task<string> EnqueueAsync(T data)

Task<IEnumerable<T>> GetDeadletterItemsAsync(CancellationToken cancellationToken = default)

Task<QueueStats> GetQueueStatsAsync()

void StartWorking(Func<QueueEntry<T>, CancellationToken, Task> handler, bool autoComplete = false, CancellationToken cancellationToken = default)