A smart and simple library for pub sub implementtion to RabbitMq
Install-Package R.BooBus.RabiitMq
dotnet add package R.BooBus.RabiitMq
1 - In the publish process, register the service in net core DI container with the fluent built in api like this:
//A instace of ServiceCollection
services.UseRabbitMq("amqp://guest:guest@localhost", "Gabriel", nameof(PublishVideoEvent));2 - Create a custom event that inherits from the Event Class of the R.Boobus.Core namespace
public class MyEvent : Event
{
}3 - We are now ready to publish the event on the bus.
public class SomeClass
{
private readonly IRabbitMQEventBus _bus;
public SomeClass(IRabbitMQEventBus bus)
{
_bus = azureServiceBus;
}
protected async Task runAsync()
{
var message = new MyEvent();
_bus.Publish(message);
}
}5 - In the subscriber process, register the service in net core DI container with the fluent built in api like this:
//A instace of ServiceCollection
services.UseRabbitMq("amqp://guest:guest@localhost", "Gabriel", nameof(PublishVideoEvent));6 - Subscribe to start receiving your message or unsubscribe to stop receiving then.
public class Worker : BackgroundService
{
private IRabbitMQEventBus _bus;
public Worker(IRabbitMQEventBus bus)
{
_bus = bus;
}
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
}
public override Task StartAsync(CancellationToken cancellationToken)
{
_bus.Subscribe<PublishVideoEvent, PublishedVideoEventHandler>();
return base.StartAsync(cancellationToken);
}
public override Task StopAsync(CancellationToken cancellationToken)
{
_bus.Unsubscribe<PublishVideoEvent, PublishedVideoEventHandler>();
return base.StopAsync(cancellationToken);
}
}7 - Create the same event created on publish process that inherits from the Event Class of the R.Boobus.Core namespace
public class MyEvent : Event
{
}8 - Create the event handler that implement IEventHandler from the R.Boobus.Core namespace
public class HelloHandler : IEventHandler<MyEvent>
{
private ILogger<HelloHandler> _logger;
public HelloHandler(ILogger<HelloHandler> logger)
{
_logger = logger;
}
public Task Handle(MyEvent @event)
{
_logger.LogInformation("Get Event from {@event} at {time}", @event.ToString(), DateTimeOffset.Now);
return Task.FromResult(true);
}
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent