Use RabbitMQ Streaming Provider for Orleans with AMQP Protocol
To install Escendit.Orleans.Streaming.RabbitMQ.StreamProtocol, run the following command in the Package Manager Console:
Install-Package Escendit.Orleans.Streaming.RabbitMQ.StreamProtocol
To use Escendit.Orleans.Streaming.RabbitMQ.StreamProtocol first register the stream provider
using the AddRabbitMq
with UseStreamProtocol
method in the Orleans configuration:
var host = Host
.CreateDefaultBuilder()
.UseOrleans(siloBuilder => siloBuilder
.AddRabbitMq("ProviderName")
.UseStreamProtocol(...)
.Build())
.Build();
var host = Host
.CreateDefaultBuilder()
.UseOrleansClient(clientBuilder => clientBuilder
.AddRabbitMq("ProviderName")
.UseStreamProtocol(...)
.Build())
.Build();
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.