StreamProtocol

RabbitMQ Client Extensions for .NET and Orleans

Escendit.AspNetCore.Builder.RabbitMQ.StreamProtocol is a NuGet package that provides the ability to register StreamSystem.

Installation

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

Install-Package Escendit.AspNetCore.Builder.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.

WebApplication
    .CreateBuilder()
    .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.

WebApplication
    .CreateBuilder()
    .AddRabbitMqStreamSystem("name", ...)

NET 8

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

NET 7

var streamSystem = serviceProvider.GetRequiredServiceByKey<object?, StreamSystem>("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.