Escendit.Extensions.DependencyInjection.RabbitMQ.AmqpProtocol 0.1.0-rc.171

RabbitMQ Client Extensions for .NET and Orleans

Escendit.Extensions.DependencyInjection.RabbitMQ.AmqpProtocol is a NuGet package that provides the ability to register IConnectionFactory or IConnection. This package is integrated with service collection.

Installation

To install Escendit.Extensions.DependencyInjection.RabbitMQ.AmqpProtocol, run the following command in the Package Manager Console:

Install-Package Escendit.Extensions.DependencyInjection.RabbitMQ.AmqpProtocol

Usage

There are several ways to register contracts that can be used in an application:

Register and use IConnectionFactory with the newly named ConnectionOptions registration.

services
    .AddRabbitMqConnectionFactory("name", ...)

.NET 8

var connectionFactory = serviceProvider.GetRequiredKeyedService<IConnectionFactory>("name");

.NET 7

var connectionFactory = serviceProvider.GetRequiredServiceByKey<object?, IConnectionFactory>("name");

Register and use IConnectionFactory with the existing ConnectionOptions registration.

services
    .AddRabbitMqConnectionFactoryFromOptions("name", "existing_name")

.NET 8

var connectionFactory = serviceProvider.GetRequiredKeyedService<IConnectionFactory>("name");

.NET 7

var connectionFactory = serviceProvider.GetRequiredServiceByKey<object?, IConnectionFactory>("name");

Register and use IConnection with the newly named ConnectionOptions and IConnectionFactory registration.

services
    .AddRabbitMqConnection("name", ...)

.NET 8

var connectionFactory = serviceProvider.GetRequiredKeyedService<IConnection>("name");

.NET 7

var connectionFactory = serviceProvider.GetRequiredServiceByKey<object? ,IConnection>("name");

Register and use IConnection with the existing IConnectionFactory registration.

Host
    .CreateDefaultBuilder()
    .AddRabbitMqConnectionFromFactory("name", "existing_name")

.NET 8

var connectionFactory = serviceProvider.GetRequiredServiceByName<IConnection>("name");

.NET 7

var connectionFactory = serviceProvider.GetRequiredServiceByKey<object?, IConnection>("name");

Contributing

If you'd like to contribute to rabbitmq-dotnet-extensions, please fork the repository and make changes as you'd like. Pull requests are warmly welcome.