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

Open in your IDE?
  1. <?php
  3. namespace Sentry\SentryBundle\EventListener;
  5. use Sentry\FlushableClientInterface;
  6. use Sentry\State\HubInterface;
  7. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  8. use Symfony\Component\Messenger\Event\WorkerMessageHandledEvent;
  9. use Symfony\Component\Messenger\Exception\HandlerFailedException;
  11. final class MessengerListener
  12. {
  13.     /**
  14.      * @var HubInterface
  15.      */
  16.     private $hub;
  18.     /**
  19.      * @var bool
  20.      */
  21.     private $captureSoftFails;
  23.     /**
  24.      * @param HubInterface $hub
  25.      * @param bool         $captureSoftFails
  26.      */
  27.     public function __construct(HubInterface $hub, bool $captureSoftFails = true)
  28.     {
  29.         $this->hub = $hub;
  30.         $this->captureSoftFails = $captureSoftFails;
  31.     }
  33.     /**
  34.      * @param WorkerMessageFailedEvent $event
  35.      */
  36.     public function onWorkerMessageFailed(WorkerMessageFailedEvent $event): void
  37.     {
  38.         if (! $this->captureSoftFails && $event->willRetry()) {
  39.             // Don't capture soft fails. I.e. those that will be scheduled for retry.
  40.             return;
  41.         }
  43.         $error = $event->getThrowable();
  45.         if ($error instanceof HandlerFailedException) {
  46.             foreach ($error->getNestedExceptions() as $nestedException) {
  47.                 $this->hub->captureException($nestedException);
  48.             }
  49.         } else {
  50.             $this->hub->captureException($error);
  51.         }
  53.         $this->flush();
  54.     }
  56.     /**
  57.      * @param WorkerMessageHandledEvent $event
  58.      */
  59.     public function onWorkerMessageHandled(WorkerMessageHandledEvent $event): void
  60.     {
  61.         // Flush normally happens at shutdown... which only happens in the worker if it is run with a lifecycle limit
  62.         // such as --time=X or --limit=Y. Flush immediately in a background worker.
  63.         $this->flush();
  64.     }
  66.     private function flush(): void
  67.     {
  68.         $client = $this->hub->getClient();
  69.         if ($client instanceof FlushableClientInterface) {
  70.             $client->flush();
  71.         }
  72.     }
  73. }