RabbitMq.Connector 0.5.11

There is a newer version of this package available.
See the version list below for details.
dotnet add package RabbitMq.Connector --version 0.5.11
NuGet\Install-Package RabbitMq.Connector -Version 0.5.11
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="RabbitMq.Connector" Version="0.5.11" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add RabbitMq.Connector --version 0.5.11
#r "nuget: RabbitMq.Connector, 0.5.11"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install RabbitMq.Connector as a Cake Addin
#addin nuget:?package=RabbitMq.Connector&version=0.5.11

// Install RabbitMq.Connector as a Cake Tool
#tool nuget:?package=RabbitMq.Connector&version=0.5.11

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)
    {
        services.AddRabbitEventBus(option => 
        {
            option.Username = "";
            option.Password = "";
            option.Port = 5672;
            option.HostName = "";
            option.ExchangeName = "";
            option.QueueName  = "";
            option.VirtualHost = "";
            option.ConsumersCount = 10;
            option.DeadLetterName = "";
        });
    }
}

Create your event by inheriting of the class Event

using RabbitMq.Connector.Model;

// Here exist the possible add Headar property in message

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

Publish your Event

public class BusinessLayer
{
    public BusinessLayer(IMediator mediator)
    {
        mediator.Publish(new RabbitMQEvent { Count = 2; });
    }
}

Consumer your Event ceated

public class Worker
{        
    private readonly IEventSubscriber _eventSubscriber;

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _eventSubscriber.Subscribe<RabbitMQEvent>()
                        .OnFailure(config => config.RetryForever());
    }
}
Product Compatible and additional computed target framework versions.
.NET net8.0 is compatible.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
0.5.17 160 1/14/2024
0.5.13 109 1/7/2024
0.5.12 140 12/19/2023
0.5.11 136 11/28/2023
0.5.10 110 11/28/2023
0.5.9 111 11/27/2023
0.5.8 137 10/27/2023
0.5.7 112 10/27/2023
0.5.6 107 10/27/2023
0.5.5 113 10/27/2023
0.5.4 98 10/27/2023
0.5.3 105 10/27/2023
0.1.15 121 10/14/2023