RabbitMq.Connector 0.5.28

RabbitMQ Connector

This package is an implementation of the connection whit RabbitMQ that using MediatR package

Get Started

RabbitMq.Connector can be installed using the Nuget package manager or the dotnet CLI.

dotnet add package RabbitMq.Connector 

Exemplo

Configuration connection credentials with RabbitMQ

using RabbitMq.Connector.IoC;

public class Startup 
{
    public void ConfigureServices(IServiceCollection services)
    {
        // Connect with UserName and Password
        services.AddRabbitEventBus(option => 
        {
            option.Username = "";
            option.Password = "";
            option.Port = 5672;
            option.HostName = "";
            option.ExchangeName = "";
            option.QueueName  = "";
            option.VirtualHost = "";
            option.ConsumersCount = 10;
            option.DeadLetterName = "";
        });

        // Or connect with Uri

        services.AddRabbitEventBusUseUri(option => 
        {
            option.QueueName = "queue-name";
            option.ExchangeName = "exchange-name";
            option.ConnectionUri = "amqp://guest:guest@localhost:5672/";
        });
    }
}

Create your event by inheriting of the class Event

using RabbitMq.Connector.Model;

// Here exist the possible add Header property in message

public class RabbitMQEvent : Event 
{
   public int Count { get; set; }
}

Publish your Event

public class BusinessLayer
{
    public BusinessLayer(IEventPublisher _publisher)
    {
        await _publisher.PublishAsync(new RabbitMQEvent { Count = 2; });
    }
}

Consumer your Event created

public class Worker
{        
    private readonly IEventSubscriber _eventSubscriber;

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _eventSubscriber.Subscribe<RabbitMQEvent>()
                        .OnFailure(config => config.RetryForever());
    }
}