-
-
Notifications
You must be signed in to change notification settings - Fork 9.6k
[Messenger] Long task after receiving the message - message is not removed from queue #31707
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
Comments
@Valantir007 Which transport are you using? Does the |
Hi @weaverryan - I'm using Amqp. Yes, it does - the "messenger:consume" command has ended successfully but message is still with status "ready"... :/ |
When the message processing in the handler takes too long, it can be that rabbitmq regards it as failed and puts the message with a redelivered header back into the queue. You could check if that is the case. |
That's right. Do you know how to fix that? |
We took a look on this problem and we found issue with rabbitmq configuration on our server where rabbitmq is. I'm sorry for unnecessary task. |
What was the issue? |
Sorry for long time answers but I had to ask our administrator. We have RabbitMq with load balancing and our administrator added option:
to configuration. Now everything works perfect. More in this post: https://serverfault.com/questions/589804/haproxy-configuration-for-rabbitmq |
Symfony version(s) affected: 4.2.9
Description
I have one handler who receives a message - limit 1. This handler should gets ids from database and send messages to another queue. This task is very long - 15k messages. When task is very long, messenger calls ack function of "Connection" object but message is not deleted from queue.
How to reproduce
Create handler and send 15k messages to another queue.
The text was updated successfully, but these errors were encountered: