vendor/handcraftedinthealps/elasticsearch-bundle/EventListener/TerminateListener.php line 44

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the ONGR package.
  5.  *
  6.  * (c) NFQ Technologies UAB <info@nfq.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace ONGR\ElasticsearchBundle\EventListener;
  14. use ONGR\ElasticsearchBundle\Service\Manager;
  15. use Symfony\Component\DependencyInjection\Container;
  17. class TerminateListener
  18. {
  19.     /**
  20.      * @var Container
  21.      */
  22.     private $container;
  24.     /**
  25.      * @var array
  26.      */
  27.     private $managers;
  29.     /**
  30.      * Constructor
  31.      *
  32.      * @param Container $container
  33.      * @param array     $managers
  34.      */
  35.     public function __construct(Container $container, array $managers)
  36.     {
  37.         $this->container = $container;
  38.         $this->managers = $managers;
  39.     }
  41.     /**
  42.      * Forces commit to elasticsearch on kernel terminate
  43.      */
  44.     public function onKernelTerminate()
  45.     {
  46.         foreach ($this->managers as $key => $value) {
  47.             if ($value['force_commit']) {
  48.                 try {
  49.                     $managerName = sprintf('es.manager.%s', $key);
  51.                     // Ignore managers who have not been initialized.
  52.                     if (!$this->container->initialized($managerName)) {
  53.                         continue;
  54.                     }
  56.                     /** @var Manager $manager */
  57.                     $manager = $this->container->get($managerName);
  58.                 } catch (\Exception $e) {
  59.                     continue;
  60.                 }
  61.                 $manager->commit();
  62.             }
  63.         }
  64.     }
  65. }