PauseThenRequeue does not work

[anton-cher93]

I try to implement some rate limiter for RabbitMq queue. In case rate limit exceeded RateLimitException have been thrown. I use PauseThenRequeue in HandlerChain but after time my handler does not resume handling messages.
Besides, message duplicates in rabbit queue.

public class OrderHandler
{
    public static void Configure(HandlerChain chain)
    {
        chain.OnException<RpsLimitException>().PauseThenRequeue(10.Seconds());
    }

    public void Handle(Order message)
    {
        // my code here
    }
}

Maybe I need to use another configuration for rate limiter?
Wolverine version: 5.12.1

[jeremydmiller]

@anton-cher93 We have tests for that behavior that are happily passing right now. I think I'd need a bit more of a reproduction than "doesn't work"

[anton-cher93]

Thanks for the answer.

Here is my code to reproduce this issue.

var builder = WebApplication.CreateBuilder(args);

builder.UseWolverine(options =>
{
    options.UseRabbitMq(rabbit =>
        {
            rabbit.HostName = "localhost";
            rabbit.Port = 5672;
            rabbit.VirtualHost = "/";
            rabbit.UserName = "guest";
            rabbit.Password = "guest";
        })
        .AutoProvision();

    options.ConfigureRabbitMq()
        .DeclareQueue("orders")
        .DeclareExchange("orders", exchange => exchange.BindQueue("orders"));
    
    options.PublishMessage<Order>()
        .ToRabbitExchange("orders");
    
    options.ListenToRabbitQueue("orders")
        .PreFetchCount(1);
});

var app = builder.Build();

app.MapGet(
    "/order",
    async ([FromServices] IMessageBus bus) => await bus.PublishAsync(new Order(Id: Guid.NewGuid())));

await app.RunJasperFxCommands(args);

public record Order(Guid Id);

[WolverineHandler]
public class OrderHandler
{
    public static void Configure(HandlerChain chain)
    {
        chain.OnException<RpsLimitException>()
            .PauseThenRequeue(10.Seconds());
    }
    
    public static void Handle(Order order)
    {
        throw new RpsLimitException();
    }
}

public class RpsLimitException : Exception;

I publish a single message into orders queue!

When I use this

chain.OnException<RpsLimitException>()
            .PauseThenRequeue(10.Seconds());

I expect listener stops listening and resume after 10 seconds.

But after 10 seconds I see another one message in queue.

[anton-cher93]

My goal is to loop message with delay till message can be processed due to RPS limit. Maybe I need to use another HandlerChain configuration?

[anton-cher93]

I just find out the solution for my problem.

chain.OnException<RpsLimitException>()
            .CustomActionIndefinitely(
                async (_, lifecycle, _) =>
                {
                    await Task.Delay(1_000);

                    await lifecycle.RetryExecutionNowAsync();
                },
                description: "test"
            );

[jeremydmiller]

@anton-cher93 Glad you got that working, not how I would have suggested doing that, but okay. If there really was a problem with that functionality, I still need to fix it. Dubious it's broken, but I still have to chase this down now.