DelayedEvents.RabbitMq 1.1.2

dotnet add package DelayedEvents.RabbitMq --version 1.1.2
NuGet\Install-Package DelayedEvents.RabbitMq -Version 1.1.2
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="DelayedEvents.RabbitMq" Version="1.1.2" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add DelayedEvents.RabbitMq --version 1.1.2
#r "nuget: DelayedEvents.RabbitMq, 1.1.2"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install DelayedEvents.RabbitMq as a Cake Addin
#addin nuget:?package=DelayedEvents.RabbitMq&version=1.1.2

// Install DelayedEvents.RabbitMq as a Cake Tool
#tool nuget:?package=DelayedEvents.RabbitMq&version=1.1.2

DelayedEvents

Build status CodeQL GitHub issues GitHub license

DelayedEvents is a library that provides a simple way to implement delayed message. For example: you can use it to implement when order is not paid in 15 minutes, cancel the order.

Nuget packages

Name Version Downloads
DelayedEvents.Abstractions nuget stats
DelayedEvents.RabbitMq nuget stats

Installation

Add following nuget reference in business project:

PM> Install-Package DelayedEvents.Abstractions

And add following nuget reference in main project:

PM> Install-Package DelayedEvents.RabbitMq

Make sure the plugins rabbitmq_delayed_message_exchange are enabled. https://blog.rabbitmq.com/posts/2015/04/scheduling-messages-with-rabbitmq/

How to use

First of all, you need to create a class that derived from the DelayedEvent class.

public class OrderPaymentCheckDelayedEvent : DelayedEvent
{
    public OrderPaymentCheckDelayedEvent(Guid orderId)
    {
        OrderId = orderId;
        DelayInSec = 15 * 60;   // Make 15 minutes delay   
    }

    public Guid OrderId { get; }
}

Then, you need to create a class that derived from the DelayedEventHandler class.

public class OrderPaymentCheckDelayedEventHandler : DelayedEventHandler<OrderPaymentCheckDelayedEvent>
{
    private readonly IOrderService _orderService;

    public OrderPaymentCheckDelayedEventHandler(IOrderService orderService)
    {
        _orderService = orderService;
    }

    public override async Task Handle(OrderPaymentCheckDelayedEvent e)
    {
        // We will cancel the order if it is not paid in 15 minutes
        await _orderService.CancelOrderIfNotPaidAsync(e.OrderId);
    }
}

Finally, you need to register the DelayedEventHandler in the Startup.cs file.

public void ConfigureServices(IServiceCollection services)
{
    services.AddDelayedEvents()
        .AddRabbitMq(options =>
        {
            options.HostName = "localhost";
            options.UserName = "guest";
            options.Password = "guest";
        })
        .AddDelayedEventHandler<OrderPaymentCheckDelayedEventHandler>();
}

Ok! Now you can publish the DelayedEvent class in the business project.

public class OrderService : IOrderService
{
    private readonly IDelayedEventPublisher _delayedEventPublisher;

    public OrderService(IDelayedEventPublisher delayedEventPublisher)
    {
        _delayedEventPublisher = delayedEventPublisher;
    }

    public async Task CreateOrderAsync(Order order)
    {
        // Create order

        // Publish the delayed event
        await _delayedEventPublisher.PublishAsync(new OrderPaymentCheckDelayedEvent(order.Id));
    }
}

Final

Leave a comment on GitHub if you have any questions or suggestions.

Turn on the star if you like this project.

License

This project is licensed under the MIT License

Product Compatible and additional computed target framework versions.
.NET net6.0 is compatible.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
1.1.2 363 10/30/2022
1.1.0 158 10/30/2022
1.0.1 164 10/30/2022
1.0.0 170 10/30/2022