QueueService.cs

public sealed class QueueService 
{
    private readonly QueueClient _queueClient;

    public QueueService(QueueServiceClient serviceClient, string container)
    {
        _queueClient = serviceClient.GetQueueClient(container.ToLower());
        if (_queueClient.Exists() is false) {
            _queueClient.CreateIfNotExists();
        }
    }
    
    // - Controllers
    
    public async Task SendToQueueAsync(string message) 
    {
        await _queueClient.SendMessageAsync(message);
    }

    public async Task SendToQueueAsync(IEnumerable<string> messages) 
    {
        var queue = new List<string>(messages);
        foreach (var message in queue) {
            await _queueClient.SendMessageAsync(message);
        }
    }
    
    public async Task<IEnumerable<QueueMessage>> FetchAllAsync() 
    {
        var queue = await _queueClient.ReceiveMessagesAsync(maxMessages: 32);
        return new List<QueueMessage>(queue);
    }
    
    public async Task<IEnumerable<QueueMessage>> FetchAllAsync(int results) 
    {
        var queue = await _queueClient.ReceiveMessagesAsync(maxMessages: results);
        return new List<QueueMessage>(queue);
    }

    public async Task<QueueMessage> FetchOneAsync() 
    {
        var message = await _queueClient.ReceiveMessageAsync();
        return message;
    }
    
    public async Task<IEnumerable<PeekedMessage>> FetchAllIncognitoAsync() 
    {
        var queue = await _queueClient.PeekMessagesAsync(maxMessages: 32);
        return new List<PeekedMessage>(queue);
    }
    
    public async Task<IEnumerable<PeekedMessage>> FetchAllIncognitoAsync(int results) 
    {
        var queue = await _queueClient.PeekMessagesAsync(maxMessages: results);
        return new List<PeekedMessage>(queue);
    }

    public async Task<PeekedMessage> FetchOneIncognitoAsync() 
    {
        var message = await _queueClient.PeekMessageAsync();
        return message;
    }
    
    public async Task ClearAll() 
    {
        await _queueClient.ClearMessagesAsync();
    }
}

QueueServiceFactory.cs

public sealed class QueueServiceFactory(QueueServiceClient serviceClient) 
{
    public QueueService Create(string container) => new(serviceClient, container);
}

Services.cs

// Program.cs

var builder = WebApplication.CreateBuilder(args);
var connect = builder.Configuration.GetConnectionString("AzureStorage");

builder.Services
    .AddSingleton((x) => new QueueServiceClient(connect))
    .AddScoped<QueueServiceFactory>();