[RabbitMQ] Error policy with RabbitMQ is apparently not working

[marcospiresvortigo]

Error policy with RabbitMQ is apparently not working. I implemented the retry policy with the move after attempts, but I noticed that the failedAttempts is not being incremented when there is an error in the consumer. It stays in an infinite loop because of this. Here are my configurations.

var endpoint = new RabbitQueueConsumerEndpoint(consumerConfiguration.Origin)
                {
                    Connection = clientConfig,
                    Queue = queueConfig,
                    ErrorPolicy = ConfigureErrorPolicies(consumerConfiguration),
                };

                _ = builder.AddInbound(endpoint, consumerConfiguration.ActiveConsumers ?? 1);

private IErrorPolicy ConfigureErrorPolicies(ConsumerConfiguration consumerConfiguration)
        {
            var policyBuilder = new ErrorPolicyBuilder();

            var retryCount = consumerConfiguration.RetryCount ?? 3;
            var secondsBetweenRetry = consumerConfiguration.SecondsBetweenRetry ?? 10;
            var deadLetterSuffix = "dead-letter";

            var deadLetterEndpoint = GetProducerEndpoint($"{consumerConfiguration.Origin}-{deadLetterSuffix}",
                consumerConfiguration.BootstrapServerKeyDeadLetter ?? consumerConfiguration.BootstrapServerKey);

            policyBuilder.Retry(retryCount, TimeSpan.FromSeconds(secondsBetweenRetry))
                .ThenMove(deadLetterEndpoint!)
                .ThenSkip();

            return policyBuilder.Build();
        }

failedAttempts always remains 1 and ends up going into an infinite loop

[marcospiresvortigo]

@BEagle1984 Could I be doing something wrong?

[BEagle1984]

I've to check this. I'll verify and report back. 👍

[marcospiresvortigo]

thank you very much

[marcospiresvortigo]

Another thing I noticed that I found strange, it says that it moved the message to the dead letter queue but when looking at the rabbitmq panel in the dead letter queue, no message arrived

Configuration move policy:

[BEagle1984]

Is this a sample project? Would it be possible to share the source code?

[marcospiresvortigo]

It's a corporate project, it's a nuget package that we built around Silverback, in order to facilitate some configurations, we have a sample api just to validate that everything is ok, I'm going to remove the sensitive parts of the project and put together a poc with just the parts techniques and send them to you, I still send them to you today.

[BEagle1984]

Just a heads-up that RabbitMQ support will be deprecated in Silverback v5. You can find more details and the reasoning in the discussion here: #237.

Contributions are welcome if someone wants to take over maintaining it!