vendor/enqueue/enqueue/Symfony/Client/FlushSpoolProducerListener.php line 22

Open in your IDE?
  1. <?php
  3. namespace Enqueue\Symfony\Client;
  5. use Enqueue\Client\SpoolProducer;
  6. use Symfony\Component\Console\ConsoleEvents;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpKernel\KernelEvents;
  10. class FlushSpoolProducerListener implements EventSubscriberInterface
  11. {
  12.     /**
  13.      * @var SpoolProducer
  14.      */
  15.     private $producer;
  17.     public function __construct(SpoolProducer $producer)
  18.     {
  19.         $this->producer = $producer;
  20.     }
  22.     public function flushMessages()
  23.     {
  24.         $this->producer->flush();
  25.     }
  27.     /**
  28.      * {@inheritdoc}
  29.      */
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         $events = [];
  34.         if (class_exists(KernelEvents::class)) {
  35.             $events[KernelEvents::TERMINATE] = 'flushMessages';
  36.         }
  38.         if (class_exists(ConsoleEvents::class)) {
  39.             $events[ConsoleEvents::TERMINATE] = 'flushMessages';
  40.         }
  42.         return $events;
  43.     }
  44. }