Cosmos.Impuestos.Mensajeria 0.0.6

Cosmos.Impuestos.Mensajeria

Extensiones de Wolverine para integrarse con el sub-dominio de Impuestos del ERP Cosmos. La publicación de solicitudes tributarias y la escucha de resultados son capacidades separables, de modo que un servicio de borde pueda publicar solicitudes sin quedar suscrito a los resultados.

Si solo necesitas los contratos (sin Wolverine), usa el paquete Cosmos.Impuestos.Contratos.

Instalación

dotnet add package Cosmos.Impuestos.Mensajeria

Configuración

El paquete ofrece la publicación y la escucha como capacidades separadas, más una conveniencia que combina ambas. Elegí según el rol del servicio:

• Servicio de borde (API de comandos, servidor MCP, gRPC) que solo necesita pedir — publica solicitudes pero NO debe reaccionar a los resultados:

  options.PublicarHaciaImpuestos();
  

• Backend persistente del subdominio que publica solicitudes Y reacciona a los resultados — usá la conveniencia (un solo servicio debe escuchar):

  options.HabilitarImpuestos("MiServicio-From-Impuestos");
  

• Solo escuchar (caso raro: la reacción vive en un servicio distinto del que publica):

  options.EscucharRespuestasImpuestos("MiServicio-From-Impuestos");
  

PublicarHaciaImpuestos() configura la publicación de CalculoTributarioSolicitado, SolicitarConfirmacionTributaria, SolicitarRegistroTributario y ReplicaDeClasificacionesSolicitada a la cola inbound canónica de Impuestos (Impuestos-Solicitudes) con Outbox durable.

EscucharRespuestasImpuestos(nombreCola) suscribe al exchange de Impuestos para recibir CalculoTributarioRealizado, RegistroTributarioEntregado, ClasificacionTributariaPublicada y ClasificacionTributariaDesactivada con Inbox durable.

⚠️ El exchange de Impuestos es fanout. EscucharRespuestasImpuestos (y por tanto HabilitarImpuestos) debe invocarlo un solo servicio del subdominio. Si dos lo invocan con la misma cola compiten por cada mensaje; con colas distintas duplican el consumo. Los servicios de borde deben usar solo PublicarHaciaImpuestos().

Ejemplo de uso

// Program.cs del servicio consumidor
builder.Host.UsarWolverineParaComandos(
    typeof(IDominioAssemblyMarker).Assembly,
    connectionString, "MiSchema",
    builder.Environment.IsDevelopment(),
    options =>
    {
        options.HabilitarRabbitMq("RabbitMQ");
        options.HabilitarOutboxParaEventosPublicos(serviceName, typeof(IContratosAssemblyMarker).Assembly);
        options.HabilitarInbox();

        // El backend del subdominio publica solicitudes y reacciona a los resultados
        options.HabilitarImpuestos("MiServicio-From-Impuestos");
    }
);

// En el handler que necesita cotizar tributos
using Cosmos.Impuestos.Contratos.Eventos;

await publicEventSender.PublishAsync(
    new CalculoTributarioSolicitado(/* conceptos, contexto, referenciaOrigen, … */));

// Consumer para recibir el resultado de la cotización, correlacionado por ReferenciaOrigen
public class CalculoRealizadoConsumer
    : ICommandHandlerAsync<CalculoTributarioRealizado>
{
    public Task HandleAsync(CalculoTributarioRealizado evento, CancellationToken ct)
    {
        // evento.ReferenciaOrigen → identifica la transacción que solicitó la cotización
        // evento.Aplicados / evento.Descartados → resultado de la cotización
        return Task.CompletedTask;
    }
}

Métodos de extensión

Dependencias

Licencia

Software propietario © 2026 Sincosoft. Todos los derechos reservados.