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. public static function getSubscribedEvents(): array
  28. {
  29. $events = [];
  31. if (class_exists(KernelEvents::class)) {
  32. $events[KernelEvents::TERMINATE] = 'flushMessages';
  33. }
  35. if (class_exists(ConsoleEvents::class)) {
  36. $events[ConsoleEvents::TERMINATE] = 'flushMessages';
  37. }
  39. return $events;
  40. }
  41. }