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

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 FOS\ElasticaBundle\Persister\Event\Events;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. class PurgePopulateQueueListener implements EventSubscriberInterface
  10. {
  11.     private $context;
  13.     public function __construct(Context $context)
  14.     {
  15.         $this->context = $context;
  16.     }
  18.     public function purgePopulateQueue(PrePersistEvent $event)
  19.     {
  20.         $options = $event->getOptions();
  21.         if (empty($options['purge_populate_queue'])) {
  22.             return;
  23.         }
  24.         if (empty($options['populate_queue'])) {
  25.             return;
  26.         }
  28.         if (method_exists($this->context, 'purge')) {
  29.             $queue = $this->context->createQueue($options['populate_queue']);
  31.             $this->context->purge($queue);
  32.         }
  34.         if (method_exists($this->context, 'purgeQueue')) {
  35.             $queue = $this->context->createQueue($options['populate_queue']);
  37.             $this->context->purgeQueue($queue);
  38.         }
  39.     }
  41.     /**
  42.      * {@inheritdoc}
  43.      */
  44.     public static function getSubscribedEvents()
  45.     {
  46.         return [
  47.             Events::PRE_PERSIST => 'purgePopulateQueue',
  48.         ];
  49.     }
  50. }