StreamProtocol

RabbitMQ Client Extensions for .NET and Orleans

Escendit.Extensions.DependencyInjection.RabbitMQ.StreamProtocol is a NuGet package that provides the ability to register StreamSystem. This package is integrated with service collection.

Installation

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

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

Usage

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

Register and use default StreamSystem with the newly named ConnectionOptions registration.

services
    .AddRabbitMqStreamSystemAsDefault(...)

.NET 8

var streamSystem = serviceProvider.GetRequiredKeyedService<StreamSystem>("Default");

.NET 7

var streamSystem = serviceProvider.GetRequiredServiceByKey<object?, StreamSystem>("Default");

Register and use StreamSystem with the newly named ConnectionOptions registration.

services
    .AddRabbitMqStreamSystem("name", ...)

.NET 8

var streamSystem = serviceProvider.GetRequiredKeyedService<StreamSystem>("name");

.NET 7

var streamSystem = serviceProvider.GetRequiredServiceByName<object?, StreamSystem>("name");

Contributing

If you'd like to contribute to Escendit.Orleans.Clients.RabbitMQ, please fork the repository and make changes as you'd like. Pull requests are warmly welcome.