I have implemented symfony messenger https://symfony.com/doc/current/messenger.html. I want to get retry count in handler class which implements MessageHandlerInterface Messenger consumer command t...

In my Symfony project, there is a queue message handler, and I have an error that randomly appears during the execution: [2022-10-12T07:31:40.060119+00:00] console.CRITICAL: Error thrown while runn...

I am facing an odd behavior of the Symfony Messenger component. I set it up according to the documentation and I am issuing a messenger:stop-workers signal on each deploy as instructed here. Howeve...

I have a Symfony website that's something inbetween an actual implementation and staging (it's used by a special client of mine). The logging is kept ON on that server because that helps when thing...

I use Messenger Component in a non-Symfony project and Doctrine as a DSN transport. Now I want to test my code and consume the messages on my local machine, but I don't know how to run the messenge...

My symfony application has multiple instances that are running in seperate docker containers. And I have configured my app.cache to use redis: framework: cache: app: cache.adapter.redis I have t...

I am developing an application that have a Symfony Messenger component installed to handle async messages. The handler of message need to check some permissions for some particulars users, li...

I'm implementing messenger in company which I work for. I found problem with routing key. I want to to send one message to two queues. Two other apps will process this queues. Everything works wel...

I'm trying to read a queued message (in RabbitMQ) that wasn't send with Symfony Messenger. It seems that Messenger adds some headers, like headers: type: App\Message\Transaction but when read...

I've been messing around with implementing AMQP using Symfony Messenger in my latest project. While the code works to my great joy i am unable to write unit tests for methods which dispatches messa...

Tools I'm using: Symfony 4.1.6 Symfony Messenger component 4.1.6 Enqueue adapter 0.1.2 Enqueue Google Cloud Pub/Sub Transport 0.8.37 My config files: #service.yaml framework: messenger: t...