ErrorLoggerPlugin.php

<?php

class ErrorLoggerPlugin extends AbstractPlugin
{
    /** @var  Logger */
    private $logger;

    public function __construct(Logger $logger)
    {
        $this->logger = $logger;
    }

    public function attachToMessageBus(MessageBus $messageBus): void
    {
        $messageBus->attach(
            MessageBus::EVENT_FINALIZE,
            function (ActionEvent $actionEvent) {
                return $this->checkForExceptions($actionEvent);
            },
            1000
        );
    }

    private function checkForExceptions(ActionEvent $actionEvent)
    {
        $exception = $actionEvent->getParam(MessageBus::EVENT_PARAM_EXCEPTION);
        if (!$exception instanceof Throwable) {
            return;
        }

        /** @var Message $message */
        $message = $actionEvent->getParam(MessageBus::EVENT_PARAM_MESSAGE);

        $this->logger->err(
            sprintf('Error handling message \'%s\': %s', $message->messageName(), $exception->getMessage()),
            [
                'message' => $message,
                'exception' => $exception,
                '_causation_id' => $message->uuid()->toString(),
                'causationData' => IdentityCausationData::fromMessage($message),
            ]
        );
    }
}