Devplus.Messaging 2.2.0

Devplus.Messaging 📬

📬 Biblioteca para integração com RabbitMQ e mensageria.

🚀 Instalação

Para instalar a biblioteca via NuGet, utilize o seguinte comando:

dotnet add package Devplus.Messaging

Ou, no Visual Studio:

1. Abra o Gerenciador de Pacotes NuGet.
2. Busque por Devplus.Messaging.
3. Clique em Instalar.

⚡ Como Usar

📦 Publicando Mensagens

using Devplus.Messaging.Interfaces;

    private readonly IMessagingPublisher _messagingPublisher;
    public TestMessageService(IMessagingPublisher messagingProducer)
    {
        _messagingPublisher = messagingProducer;
    }
    public async Task SendMessage()
    {
        await _messagingPublisher.PublishAsync(exchangeName: "devplus-test-exchange",
                                                message: "{responseData: \"Test message from TestMessageService\"}",
                                                source: "devplus.test.app",
                                                typeEvent: "test-event");
    }

📩 Consumindo Mensagens

using Devplus.Messaging.Interfaces;
using Devplus.Messaging.Models;

namespace Devplus.TestApp.Consumers;
public class TestConsumer : IMessagingConsumer
{
    public string QueueName => "devplus-test-queue";
    public string ExchangeName => "devplus-test-exchange";
    public string RoutingKey => "";
    public int MaxRetry => 3;

    private readonly ILogger<TestConsumer> _logger;

    public TestConsumer(ILogger<TestConsumer> logger)
    {
        _logger = logger;
    }

    public Task ConsumeAsync(CloudEvent<object> cloudEvent, CancellationToken cancellationToken)
    {
        _logger.LogInformation("Received message: {Message}", cloudEvent.Data);
        return Task.CompletedTask;
    }
}

QueueName e ExchangeName são obrigatórios para a lib realizar o bind no RabbitMq. MaxRetry configura o numero máximo de tentativas que a menssagem é processada até ser enviada para DLQ.

🔧 Configuração via appsettings.json

{
  "RabbitMq": {
    "Host": "localhost",
    "Port": "5672",
    "Username": "user",
    "Password": "pass",
    "VHost": "my_vhost"
  }
}

E no Program.cs:

var configuration = new ConfigurationBuilder()
    .AddJsonFile("appsettings.json")
    .Build();

builder.Services.AddMessaging(builder.Configuration);
builder.Services.AddScoped<ITestMessageService, TestMessageService>();
builder.Services.AddScoped<IMessagingConsumer, TestConsumer>();
builder.Services.AddScoped<TestConsumer>();

🛠 Compatibilidade

📌 Funcionalidades

✅ Suporte ao RabbitMQ com publicação e consumo de mensagens.
✅ Injeção de dependência via IServiceCollection.
✅ Configuração via appsettings.json.
✅ Compatível com .NET 6, .NET 7 e .NET 8.

🏗 Contribuindo

Se você quiser contribuir para este projeto:

1. Fork o repositório.
2. Crie uma branch (git checkout -b feature/nova-feature).
3. Faça commit das alterações (git commit -m "Add nova feature").
4. Envie um Pull Request.

📄 Licença

Este projeto está licenciado sob a MIT License.

📞 Contato

📧 Email: clayton@devplus.com.br
🔗 LinkedIn: Clayton Oliveira
🚀 Devplus Consultoria: www.devplus.com.br