Namespace FoundationaLLM.DataPipelineEngine.Services.Queueing

Classes

AzureStorageQueueService<T>

Provides an implementation of the IMessageQueueService interface for Azure Storage Queues.

ProcessingPayloadsRegistry<T>

Maintains a registry of payloads that are currently being processed.