Devplus.Messaging 1.0.2

Devplus.Messaging 📬

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

🚀 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(queueName: "devplus-test-queue",
                                                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";
    private readonly ILogger<TestConsumer> _logger;
    public TestConsumer(ILogger<TestConsumer> logger)
    {
        _logger = logger;
    }
    public Task HandleMessageAsync(CloudEvent<object> cloudEvent, CancellationToken cancellationToken)
    {
        _logger.LogInformation("Received message: {Message}", cloudEvent.Data);
        return Task.CompletedTask;
    }
}

🔧 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);

🛠 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