RepletoryLib.Messaging.RabbitMQ 1.0.0

RepletoryLib.Messaging.RabbitMQ

MassTransit-based RabbitMQ implementation of IMessagePublisher and IEventBus.

Part of the RepletoryLib ecosystem -- standalone, reusable .NET 10 libraries with zero business logic.

Overview

RepletoryLib.Messaging.RabbitMQ provides a production-ready implementation of IMessagePublisher and IEventBus from RepletoryLib.Messaging.Abstractions using MassTransit with RabbitMQ transport. It supports consumer registration, dead letter queues, configurable concurrency, and retry policies.

Key Features

• MassTransit integration -- Built on MassTransit for robust messaging patterns
• Consumer registration -- Register message consumers via the configuration callback
• Dead letter queues -- Automatic DLQ for failed messages
• Configurable concurrency -- Prefetch count and concurrent message limits
• Retry policies -- Built-in retry with configurable count and interval

Installation

dotnet add package RepletoryLib.Messaging.RabbitMQ

Dependencies

Prerequisites

• RabbitMQ 3+ with management plugin

docker-compose up -d rabbitmq

Quick Start

using RepletoryLib.Messaging.RabbitMQ;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddRepletoryRabbitMQ(builder.Configuration, cfg =>
{
    cfg.AddConsumer<OrderCreatedConsumer>();
    cfg.AddConsumer<PaymentProcessedConsumer>();
});

{
  "Messaging": {
    "RabbitMQ": {
      "Host": "localhost",
      "Port": 5672,
      "VirtualHost": "/",
      "Username": "repletory",
      "Password": "Repletory@123!",
      "RetryCount": 3,
      "RetryIntervalSeconds": 5,
      "PrefetchCount": 16,
      "ConcurrentMessageLimit": 1,
      "EnableDeadLetterQueue": true
    }
  }
}

Configuration

RabbitMqOptions

Usage Examples

Publishing Events

using RepletoryLib.Messaging.Abstractions.Interfaces;

public class OrderService
{
    private readonly IMessagePublisher _publisher;

    public OrderService(IMessagePublisher publisher) => _publisher = publisher;

    public async Task CreateOrderAsync(Order order)
    {
        await _repository.SaveAsync(order);
        await _publisher.PublishAsync(new OrderCreatedEvent
        {
            OrderId = order.Id,
            CustomerId = order.CustomerId,
            Total = order.Total
        });
    }
}

Creating a Consumer

using RepletoryLib.Messaging.Abstractions.Interfaces;
using RepletoryLib.Messaging.Abstractions.Models;

public class OrderCreatedConsumer : IMessageConsumer<OrderCreatedEvent>
{
    private readonly IEmailService _email;

    public OrderCreatedConsumer(IEmailService email) => _email = email;

    public async Task ConsumeAsync(ConsumeContext<OrderCreatedEvent> context,
        CancellationToken cancellationToken = default)
    {
        await _email.SendOrderConfirmationAsync(context.Message.OrderId);
    }
}

Using IEventBus for Commands

using RepletoryLib.Messaging.Abstractions.Interfaces;

// Send a command to a specific queue (point-to-point)
await _eventBus.SendAsync(new ProcessPaymentCommand
{
    OrderId = orderId,
    Amount = 500m
}, "queue:payment-processor");

Integration with Other RepletoryLib Packages

Troubleshooting

License

This project is licensed under the MIT License.

Copyright (c) 2024-2026 Repletory.

For complete documentation, infrastructure setup, and configuration reference, see the RepletoryLib main repository.