pkg

romuloedu/SquareLabs.OracleAQ.Extensionsv1.0.0

.NET 8.0

Uma biblioteca .NET leve e resiliente para criar listeners (Hosted Services) para o Oracle Advanced Queuing (AQ). Integra-se com injeção de dependência para descobrir e gerenciar seus processadores de mensagens de forma automática, com lógica de reconexão e mapeamento de UDTs embutidos.

License

MIT

Deps

2

Install Size

—

Vulns

✓ 0

Published

Oct 9, 2025

Get Started

$ dotnet add package SquareLabs.OracleAQ.Extensions

Readme

Oracle AQ Extensions for .NET

Uma biblioteca .NET leve e resiliente para criar listeners (Hosted Services) para o Oracle Advanced Queuing (AQ). Integra-se com injeção de dependência para descobrir e gerenciar seus processadores de mensagens de forma automática, com lógica de reconexão e mapeamento de UDTs embutidos.

🤔 Por que usar esta biblioteca?

Interagir com o Oracle Advanced Queuing em uma aplicação .NET moderna pode ser verboso e complexo, especialmente ao tentar criar serviços de background robustos e resilientes. Esta biblioteca abstrai toda a complexidade de gerenciamento de conexões, transações de fila, mapeamento de objetos e descoberta de serviços, permitindo que você foque no que realmente importa: a sua lógica de negócio.

✨ Principais Recursos

🚀 Descoberta Automática: Apenas implemente a interface IOracleAQListener<T> e a biblioteca irá descobrir, registrar e executar seu listener automaticamente.
🔌 Integração com DI: Desenhado desde o início para funcionar perfeitamente com o container de injeção de dependência do .NET. Injete qualquer serviço (como um DbContext do EF Core ou um IHubContext do SignalR) em seus listeners.
💪 Resiliência Embutida: O serviço de escuta lida automaticamente com perdas de conexão com o Oracle, esperando um tempo e tentando se reconectar, garantindo que sua aplicação continue funcionando.
🔄 Mapeamento de UDT: Mapeie os User-Defined Types (UDT) do Oracle para classes C# (POCOs) de forma limpa e declarativa usando atributos.
🏗️ Arquitetura Limpa: Construído com os princípios da Clean Architecture para garantir um código desacoplado, testável e de fácil manutenção.

dotnet add package SquareLabs.OracleAQ.Extensions

using Oracle.ManagedDataAccess.Client;
using Oracle.ManagedDataAccess.Types;

public class PedidoUdtFactory : IOracleCustomType, IOracleCustomTypeFactory
{
    // Implementação da factory para mapear o UDT Oracle para a classe C#
    [OracleObjectMapping("ID")]
    public decimal? Id { get; set; }

    [OracleObjectMapping("DESCRICAO")]
    public string? Descricao { get; set; }

    [OracleObjectMapping("VALOR")]
    public decimal? Valor { get; set; }

    public IOracleCustomType CreateObject()
    {
        return new PedidoUdtFactory();
    }

    public void FromCustomObject(OracleConnection con, object udt)
    {
        if (udt is PedidoDto pedido)
        {
            Id = pedido.Id;
            Descricao = pedido.Descricao;
            Valor = pedido.Valor;
        }
    }

    public void ToCustomObject(OracleConnection con, object udt)
    {
        // Conversão do UDT Oracle para o objeto customizado
    }
}

using SquareLabs.OracleAQ.Extensions.Domain.Attributes;

public class PedidoDto
{
    [OracleUdtProperty("ID")]
    public decimal? Id { get; set; }

    [OracleUdtProperty("DESCRICAO")]
    public string? Descricao { get; set; }

    [OracleUdtProperty("VALOR")]
    public decimal? Valor { get; set; }
}

using Microsoft.Extensions.Logging;
using SquareLabs.OracleAQ.Extensions.Domain.Interfaces;

public class PedidoListener : IOracleAQListener<PedidoDto>
{
    private readonly ILogger<PedidoListener> _logger;
    private readonly IPedidoService _pedidoService;

    public PedidoListener(ILogger<PedidoListener> logger, IPedidoService pedidoService)
    {
        _logger = logger;
        _pedidoService = pedidoService;
    }

    public string QueueName => "PEDIDOS_QUEUE";

    public async Task ProcessMessageAsync(PedidoDto message, CancellationToken cancellationToken)
    {
        _logger.LogInformation("Processando pedido {PedidoId}", message.Id);
        
        try
        {
            await _pedidoService.ProcessarPedidoAsync(message, cancellationToken);
            _logger.LogInformation("Pedido {PedidoId} processado com sucesso", message.Id);
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Erro ao processar pedido {PedidoId}", message.Id);
            throw; // Re-throw para que a mensagem seja colocada de volta na fila
        }
    }
}

using SquareLabs.OracleAQ.Extensions.Infrastructure;

var builder = WebApplication.CreateBuilder(args);

// Registrar seus serviços de negócio
builder.Services.AddScoped<IPedidoService, PedidoService>();

// Registrar os listeners Oracle AQ
builder.Services.AddOracleAQListeners(options =>
{
    options.ConnectionStringName = "OracleConnection";
    
    // Configurar o mapeamento UDT
    options.RegisterQueueUdt("PEDIDOS_QUEUE", "PEDIDO_UDT");
    
    // NOVO: Para Oracle 10g, habilite o modo de compatibilidade
    // options.UseOracle10gCompatibilityMode = true;
});

var app = builder.Build();

// Configure o pipeline HTTP...

app.Run();

{
  "ConnectionStrings": {
    "OracleConnection": "Data Source=localhost:1521/XE;User Id=seu_usuario;Password=sua_senha;"
  }
}

ORA-06550: linha 1, coluna 13:
PLS-00306: número incorreto de tipos de argumentos na chamada para 'GET_TYPE_SHAPE'

services.AddOracleAQListeners(options =>
{
    options.ConnectionStringName = "OracleConnection";
    options.RegisterQueueUdt("SUA_FILA", "SEU_TIPO_UDT");
    
    // Habilita modo de compatibilidade com Oracle 10g
    options.UseOracle10gCompatibilityMode = true;
});