Closed
Description
Symfony version(s) affected: 4.2
Description
Messenger worker fail after handling message with empty body (or headers) and restart this process in loop. Other messages in queue become blocked.
No way to catch this exception in middleware or handler.
How to reproduce
- Start worker
php bin/console messenger:consume-messages some_transport
. - Add message with empty headers to queue.
- Worker fail and restart handling invalid message in loop.
Possible Solution
- Add additional catch block for
Symfony\Component\Messenger\Exception\InvalidArgumentException
to reject message. - Add error handler for serializer in
Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceiver
Additional context