Marquitos.Events

A simple event system in top of RabbitMQ using EasyNetQ for AspNetCore applications.

Usage

To notify an event, first create a class that implements the IEvent interface.

    // Your event class
    public class ExampleCreated : IEvent
    {
        /// <summary>
        /// The example name just created
        /// </summary>
        public string ExampleName { get; set; } = "My Example";
    }

Then inject IEventService to your service and call NotifyAsync to notify your event.

    // Your Service class that notifies events
    public class ExampleService
    {
        private readonly IEventService _eventService;

        public WeatherForecastController(IEventService eventService)
        {
            _eventService = eventService;
        }

        public async Task CreateExampleAsync(string name, CancellationToken cancellationToken = default)
        {
            // call repository to register the example name

            // then notify your event to RabbitMQ
            await _eventService.NotifyAsync(new ExampleCreated() { ExampleName = name });
        }
    }

To consume an event create an event consumer. First create a class that descends of EventConsumer.

    public class ExampleConsumer : EventConsumer<ExampleCreated>
    {
        public override async Task HandleMessageAsync(ExampleCreated message, CancellationToken cancellationToken = default)
        {
            Console.WriteLine("Received an message!");
            await Task.CompletedTask;
        }
    }

Then register the RabbitMQ Consumer Service Engine and the Event Consumer on your services configuration.

...
    // Register the RabbitMQ connections string
    builder.Services.AddRabbitMQConnectionWithSystemTextJson(builder.Configuration.GetConnectionString("RabbitConnection"));

    // Register the Event Service to notify events
    builder.Services.AddRabbitMQEventService();

    // Register the Consumer Service Engine
    builder.Services.AddRabbitMQConsumerService();

    // Register your Consumer
    builder.Services.AddRabbitMQEventConsumer<ExampleConsumer, ExampleCreated>((sp, o) =>
    {
        // For example add two retry options
        o.Retries = new[] { 0.5, 1 }; // 30s and 1min
        o.IsEnabled = true;
    });
...