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

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 OldSound\RabbitMqBundle\DependencyInjection\Compiler\ServiceContainerPass;
  8. use Symfony\Component\HttpKernel\Bundle\Bundle;
  9. use Symfony\Component\DependencyInjection\ContainerBuilder;
  11. class OldSoundRabbitMqBundle extends Bundle
  12. {
  13. public function build(ContainerBuilder $container): void
  14. {
  15. parent::build($container);
  17. $container->addCompilerPass(new RegisterPartsPass());
  18. $container->addCompilerPass(new InjectEventDispatcherPass());
  19. $container->addCompilerPass(new ServiceContainerPass());
  20. }
  22. /**
  23. * {@inheritDoc}
  24. */
  25. public function shutdown(): void
  26. {
  27. parent::shutdown();
  28. if (!$this->container->hasParameter('old_sound_rabbit_mq.base_amqp')) {
  29. return;
  30. }
  31. $connections = $this->container->getParameter('old_sound_rabbit_mq.base_amqp');
  32. foreach ($connections as $connection) {
  33. if ($this->container->initialized($connection)) {
  34. $this->container->get($connection)->close();
  35. }
  36. }
  37. }
  38. }