src/Aqarmap/Bundle/MainBundle/EventListener/ElasticaPopulateSubscriber.php line 22

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\MainBundle\EventListener;
  5. use FOS\ElasticaBundle\Persister\Event\Events;
  6. use FOS\ElasticaBundle\Persister\Event\PrePersistEvent;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. class ElasticaPopulateSubscriber implements EventSubscriberInterface
  10. {
  11.     public static function getSubscribedEvents(): array
  12.     {
  13.         return [Events::PRE_PERSIST => 'onPrePersist'];
  14.     }
  16.     /**
  17.      * Workaround to fix the error "Overall reply time (180 seconds) has been exceeded." while populating elastic
  18.      * using Enqueue.
  19.      *
  20.      * Ref: https://github.com/FriendsOfSymfony/FOSElasticaBundle/issues/1453
  21.      */
  22.     public function onPrePersist(PrePersistEvent $event): void
  23.     {
  24.         $options = $event->getOptions();
  25.         $options = array_replace($options, [
  26.             'limit_overall_reply_time' => 90 * 60 * 60, // sec ( 90 minutes ... )
  27.         ]);
  29.         $event->setOptions($options);
  30.     }
  31. }