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

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.     /**
  18.      * @param SpoolProducer $producer
  19.      */
  20.     public function __construct(SpoolProducer $producer)
  21.     {
  22.         $this->producer = $producer;
  23.     }
  25.     public function flushMessages()
  26.     {
  27.         $this->producer->flush();
  28.     }
  30.     /**
  31.      * {@inheritdoc}
  32.      */
  33.     public static function getSubscribedEvents()
  34.     {
  35.         $events = [];
  37.         if (class_exists(KernelEvents::class)) {
  38.             $events[KernelEvents::TERMINATE] = 'flushMessages';
  39.         }
  41.         if (class_exists(ConsoleEvents::class)) {
  42.             $events[ConsoleEvents::TERMINATE] = 'flushMessages';
  43.         }
  45.         return $events;
  46.     }
  47. }