-
Notifications
You must be signed in to change notification settings - Fork 430
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Redis redelivery_delay setting does not work #1342
Comments
compwright
added a commit
to compwright/enqueue-dev
that referenced
this issue
Mar 18, 2024
When using the redis transport, RedisConsumer::processResult() creates the redelivered record prior to the RedisSubscription callback executing. The subscription callback attached with Enqueue\Consumption\QueueConsumer then invokes RedisConsumer::reject(). Calling acknowledge() deletes the redelivered record which was created earlier. Thus, we should not create a new record in reject() and we should only call acknowledge() if we do not wish to redeliver. I have tested and confirmed that this change fixes the issue. However, if there is a better solution, please advise. Resolves php-enqueue#1342
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Redis messages are delivered immediately, back-to-back, not respecting either the default redelivery_delay setting (300) or a custom setting.
The text was updated successfully, but these errors were encountered: