CodeQuartz.Portal 1.0.0

CodeQuartz.Portal.RabbitMQ

A simple and extensible RabbitMQ integration library for .NET applications.

This library provides a lightweight abstraction over RabbitMQ to simplify message publishing and consumption using common patterns like dependency injection (ISender, IReceiver), fluent configuration, and support for multiple queues.

✨ Features

• 📤 Publish messages with automatic JSON serialization.
• 📥 Consume messages asynchronously with built-in ACK/NACK control.
• ⚙️ Easy integration with IServiceCollection and dependency injection.
• 🔄 Supports durable queues and custom exchange/queue settings.
• 🔐 Built-in configuration for multiple queues and secure connection options.

🚀 Installation

Install via NuGet:

dotnet add package CodeQuartz.Portal

🧩 Configuration

1. Register the sender

services.AddPortalSender(options =>
{
    options.Exchange = "my-exchange";
    options.ExchangeType = "direct";
    options.Queues = ["queue-a", "queue-b"];
    options.HostConfig = new QueueConfiguration
    {
        Host = "localhost",
        Port = 5672,
        Username = "guest",
        Password = "guest"
    };
});

📤 Sending Messages

public class HelloCommand
{
    public required string Name { get; set; }
}

public class QueueService
{
    private readonly ISender _sender;

    public QueueService(ISender sender)
    {
        _sender = sender;
    }

    public async Task SendMessage()
    {
        var command = new HelloCommand { Name = "Test" };
        await _sender.Send("queue-a", command);
    }
}

📥 Listening for Messages

var portal = new PortalBuilder(new QueueOptions
{
    Exchange = "my-exchange",
    Queues = ["queue-a"],
    HostConfig = new QueueConfiguration
    {
        Host = "localhost",
        Port = 5672,
        Username = "guest",
        Password = "guest"
    }
}).UsePortal().GetAwaiter().GetResult();

var receiver = new PortalReceiver(portal, "my-exchange");
await receiver.Listen<HelloCommand>("queue-a", autoAck: false, async command =>
{
    Console.WriteLine($"Received: {command.Name}");
    return true;
});

receiver.Run();

🛠️ Components

PortalSender

• Publishes messages using an IChannel.
• JSON-serializes objects before publishing.
• Injectable via ISender.

PortalReceiver

• Listens to a specific queue.
• Deserializes messages and handles acknowledgment based on the callback's result.

PortalBuilder

• Initializes the RabbitMQ connection and channel.
• Declares exchanges and queues, and binds queues to the exchange.

✅ Requirements

• .NET 8 or later
• Running RabbitMQ Server

📄 License

This project is licensed under the MIT License.

🤝 Contributing

Contributions are welcome! Feel free to open issues or pull requests with improvements, bug fixes, or suggestions.

🧠 Author

Developed with ❤️ by Daniel Lopes