This is an alternative to #35453. It will fix #34414 and fix #35360.

framework:
    messenger:
        buses:
            command_bus:
                middleware:
                    - stop_worker_on_exceptions: [['App\Exception\Foo', 'Doctrine\ORM\ORMException']]

If any of these exceptions is thrown when handling a message in "command_bus" we will stop all workers.

You may also be more defensive:

framework:
    messenger:
        buses:
            command_bus:
                middleware:
                    - stop_worker_on_exceptions: [['*']]

This will avoid situation where you have 100 messages on the queue, and when handling message 5 it causes an exception that closes the EntityManager. As a result the other 95 messages will also fail because "The EntityManager is closed."

Drawback of this approach. This will stop ALL workers, even workers in other threads. It will also stop all workers even if the message was handled synchronously.

This is a draft PR, which means that Im not done with the implementation. I want some feedback before I add tests, documentation and possibly trying to fix some of the drawbacks.