Escendit.Orleans.Streaming.RabbitMQ.AmqpProtocol 0.2.1-rc.3

RabbitMQ Orleans AMQP Protocol Streaming Provider

Use RabbitMQ Streaming Provider for Orleans with AMQP Protocol

Installation

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

Install-Package Escendit.Orleans.Streaming.RabbitMQ.AmqpProtocol

Usage

To use Escendit.Orleans.Streaming.RabbitMQ.AmqpProtocol first register the stream provider using the AddRabbitMq with UseAmqpProtocol method in the Orleans configuration:

SiloBuilder

var host = Host
    .CreateDefaultBuilder()
    .UseOrleans(siloBuilder => siloBuilder
        .AddRabbitMq("ProviderName")
        .UseAmqpProtocol(...)
        .Build())
    .Build();

ClientBuilder

var host = Host
    .CreateDefaultBuilder()
    .UseOrleansClient(clientBuilder => clientBuilder
        .AddRabbitMq("ProviderName")
        .UseAmqpProtocol(...)
        .Build())
    .Build();

Contributing

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