vendor/php-amqplib/rabbitmq-bundle/OldSoundRabbitMqBundle.php line 10

Open in your IDE?
  1. <?php
  3. namespace OldSound\RabbitMqBundle;
  5. use OldSound\RabbitMqBundle\DependencyInjection\Compiler\InjectEventDispatcherPass;
  6. use OldSound\RabbitMqBundle\DependencyInjection\Compiler\RegisterPartsPass;
  7. use Symfony\Component\HttpKernel\Bundle\Bundle;
  8. use Symfony\Component\DependencyInjection\ContainerBuilder;
  10. class OldSoundRabbitMqBundle extends Bundle
  11. {
  12.     public function build(ContainerBuilder $container)
  13.     {
  14.         parent::build($container);
  16.         $container->addCompilerPass(new RegisterPartsPass());
  17.         $container->addCompilerPass(new InjectEventDispatcherPass());
  18.     }
  20.     /**
  21.      * {@inheritDoc}
  22.      */
  23.     public function shutdown()
  24.     {
  25.         parent::shutdown();
  26.         if (!$this->container->hasParameter('old_sound_rabbit_mq.base_amqp')) {
  27.             return;
  28.         }
  29.         $connections = $this->container->getParameter('old_sound_rabbit_mq.base_amqp');
  30.         foreach ($connections as $connection) {
  31.             if ($this->container->initialized($connection)) {
  32.                 $this->container->get($connection)->close();
  33.             }
  34.         }
  35.     }
  36. }