Всем привет!
сорят, что прерываю тут вашу милую беседу)
у меня вопрос по поводу компонента symfony/messenger.
сейчас проект работает не на symfony.
но используем некоторые его компоненты.
для обработки фоновых задач, мы используем rabbitmq и php-консюмеры.
сами консюмеры работает через php-amqplib.
консюмер обработки очереди задач, обрабатывает по 10 сообщений и завершается, и так по кругу. все это конролирует супервизор.
сообщений в очереди может сразу прилететь 10к, а может и в течении дня не быть ни одного.
если весь день консюмер висит и слушает очередь, то при появлении первого же сообщения, консюмер падает с ошибкой
Uncaught Exception PhpAmqpLib\Exception\AMQPHeartbeatMissedException: "Missed server heartbeat
т.к. пока консюмер слушал очередь, то не мог асинхронно отправлять признаки жизни.
как решить эту проблему так и не разобрался.
подскажите плз, имеет ли смыл юзать symfony/messenger может ли как-то помочь в решении проблемы?