Reservation.cs

public class ReserveOrderHandler : IHandleMessages<ReserveOrder>
{
    private readonly Reservation _reservation;

    public ReserveOrderHandler(Reservation reservation)
    {
        _reservation = reservation;
    }

    public async Task Handle(ReserveOrder message, IMessageHandlerContext context)
    {
        if (_reservation.Reserve(message.OrderId))
        {
            var expireOptions = new SendOptions();
            expireOptions.DelayDeliveryWith(TimeSpan.FromDays(7));
            await context.Send(new ExpireReservation { OrderId = message.OrderId }, expireOptions);

            await context.Publish(new OrderReserved { OrderId = message.OrderId });
        }
    }
}