vendor/sentry/sentry-symfony/src/EventListener/MessengerListener.php line 42

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Sentry\SentryBundle\EventListener;
  7. use Sentry\State\HubInterface;
  8. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  9. use Symfony\Component\Messenger\Event\WorkerMessageHandledEvent;
  10. use Symfony\Component\Messenger\Exception\HandlerFailedException;
  12. final class MessengerListener
  13. {
  14.     /**
  15.      * @var HubInterface The current hub
  16.      */
  17.     private $hub;
  19.     /**
  20.      * @var bool Whether to capture errors thrown while processing a message that
  21.      *           will be retried
  22.      */
  23.     private $captureSoftFails;
  25.     /**
  26.      * @param HubInterface $hub              The current hub
  27.      * @param bool         $captureSoftFails Whether to capture errors thrown
  28.      *                                       while processing a message that
  29.      *                                       will be retried
  30.      */
  31.     public function __construct(HubInterface $hub, bool $captureSoftFails = true)
  32.     {
  33.         $this->hub = $hub;
  34.         $this->captureSoftFails = $captureSoftFails;
  35.     }
  37.     /**
  38.      * This method is called for each message that failed to be handled.
  39.      *
  40.      * @param WorkerMessageFailedEvent $event The event
  41.      */
  42.     public function handleWorkerMessageFailedEvent(WorkerMessageFailedEvent $event): void
  43.     {
  44.         if (!$this->captureSoftFails && $event->willRetry()) {
  45.             return;
  46.         }
  48.         $error = $event->getThrowable();
  50.         if ($error instanceof HandlerFailedException) {
  51.             foreach ($error->getNestedExceptions() as $nestedException) {
  52.                 $this->hub->captureException($nestedException);
  53.             }
  54.         } else {
  55.             $this->hub->captureException($error);
  56.         }
  58.         $this->flushClient();
  59.     }
  61.     /**
  62.      * This method is called for each handled message.
  63.      *
  64.      * @param WorkerMessageHandledEvent $event The event
  65.      */
  66.     public function handleWorkerMessageHandledEvent(WorkerMessageHandledEvent $event): void
  67.     {
  68.         // Flush normally happens at shutdown... which only happens in the worker if it is run with a lifecycle limit
  69.         // such as --time=X or --limit=Y. Flush immediately in a background worker.
  70.         $this->flushClient();
  71.     }
  73.     private function flushClient(): void
  74.     {
  75.         $client = $this->hub->getClient();
  77.         if (null !== $client) {
  78.             $client->flush();
  79.         }
  80.     }
  81. }