KamuIlanlar.Core.Messaging.MassTransit.DependencyInjection 1.0.0

Core.Messaging.MassTransit.DependencyInjection

Dependency injection extensions for KamuIlanlar Core.Messaging.MassTransit package. Provides fluent configuration API for setting up messaging with RabbitMQ.

🚀 Features

• Fluent Configuration: Easy-to-use configuration API
• Auto-Registration: Automatic consumer registration
• RabbitMQ Setup: Complete RabbitMQ configuration
• Retry Policies: Configurable retry mechanisms
• Health Checks: Built-in health check support
• Environment Configuration: Support for different environments

📦 Installation

dotnet add package KamuIlanlar.Core.Messaging.MassTransit.DependencyInjection

🔧 Usage

Basic Configuration

// Program.cs or Startup.cs
builder.Services.AddMessaging(config =>
{
    config.UseMassTransit(options =>
    {
        options.Host("rabbitmq://localhost")
               .Credentials("guest", "guest")
               .VirtualHost("/")
               .ConfigureEndpoints()
               .AddConsumer<OrderCreatedEvent, OrderCreatedConsumer>();
    });
});

Advanced Configuration

builder.Services.AddMessaging(config =>
{
    config.UseMassTransit(options =>
    {
        var rabbitMqConfig = builder.Configuration.GetSection("RabbitMQ");

        options.Host(rabbitMqConfig["Host"])
               .Credentials(rabbitMqConfig["Username"], rabbitMqConfig["Password"])
               .VirtualHost(rabbitMqConfig["VirtualHost"])
               .ConfigureEndpoints()
               .ConfigureRetry(retry =>
               {
                   retry.ImmediateRetryCount = 3;
                   retry.DelayedRetryCount = 5;
                   retry.InitialInterval = TimeSpan.FromSeconds(1);
               })
               .AddConsumer<OrderCreatedEvent, OrderCreatedConsumer>()
               .AddConsumer<PaymentProcessedEvent, PaymentProcessedConsumer>();
    });
});

Configuration Options

{
  "RabbitMQ": {
    "Host": "localhost",
    "Username": "guest",
    "Password": "guest",
    "VirtualHost": "/"
  }
}

🏗️ API Reference

MessagingConfiguration

• UseMassTransit(Action<MassTransitConfiguration>): Configure MassTransit provider

MassTransitConfiguration

• Host(string): Set RabbitMQ host
• Credentials(string, string): Set username/password
• VirtualHost(string): Set virtual host
• ConfigureEndpoints(): Enable automatic endpoint configuration
• ConfigureRetry(Action<RetryOptions>): Configure retry policies
• AddConsumer<TEvent, TConsumer>(): Register event consumer

RetryOptions

• ImmediateRetryCount: Number of immediate retries (default: 3)
• DelayedRetryCount: Number of delayed retries (default: 3)
• InitialInterval: Initial retry delay (default: 1 second)
• IntervalIncrement: Retry delay increment (default: 1 second)

📋 Requirements

• .NET 9.0 or later
• Microsoft.Extensions.DependencyInjection
• Core.Messaging.Abstractions
• Core.Messaging.MassTransit

🤝 Contributing

Please see the main repository contributing guidelines.

📄 License

MIT License