vendor/enqueue/elastica-bundle/Persister/Listener/PurgePopulateQueueListener.php line 17

Open in your IDE?
  1. <?php
  2. namespace Enqueue\ElasticaBundle\Persister\Listener;
  4. use FOS\ElasticaBundle\Persister\Event\PrePersistEvent;
  5. use Interop\Queue\Context;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. class PurgePopulateQueueListener implements EventSubscriberInterface
  9. {
  10.     private $context;
  12.     public function __construct(Context $context)
  13.     {
  14.         $this->context = $context;
  15.     }
  17.     public function purgePopulateQueue(PrePersistEvent $event)
  18.     {
  19.         $options = $event->getOptions();
  20.         if (empty($options['purge_populate_queue'])) {
  21.             return;
  22.         }
  23.         if (empty($options['populate_queue'])) {
  24.             return;
  25.         }
  27.         if (method_exists($this->context, 'purge')) {
  28.             $queue = $this->context->createQueue($options['populate_queue']);
  30.             $this->context->purge($queue);
  31.         }
  33.         if (method_exists($this->context, 'purgeQueue')) {
  34.             $queue = $this->context->createQueue($options['populate_queue']);
  36.             $this->context->purgeQueue($queue);
  37.         }
  38.     }
  40.     /**
  41.      * {@inheritdoc}
  42.      */
  43.     public static function getSubscribedEvents()
  44.     {
  45.         return [
  46.             PrePersistEvent::class => 'purgePopulateQueue',
  47.         ];
  48.     }
  49. }