vendor/symfony/swiftmailer-bundle/EventListener/EmailSenderListener.php line 41

Open in your IDE?
  1. <?php
  3. /*
  4. * This file is part of the Symfony package.
  5. *
  6. * (c) Fabien Potencier <fabien@symfony.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 Symfony\Bundle\SwiftmailerBundle\EventListener;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\Console\ConsoleEvents;
  16. use Symfony\Component\DependencyInjection\ContainerInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpKernel\KernelEvents;
  20. /**
  21. * Sends emails for the memory spool.
  22. *
  23. * Emails are sent on the kernel.terminate event.
  24. *
  25. * @author Fabien Potencier <fabien@symfony.com>
  26. */
  27. class EmailSenderListener implements EventSubscriberInterface
  28. {
  29. private $container;
  31. private $logger;
  33. private $wasExceptionThrown = false;
  35. public function __construct(ContainerInterface $container, LoggerInterface $logger = null)
  36. {
  37. $this->container = $container;
  38. $this->logger = $logger;
  39. }
  41. public function onException()
  42. {
  43. $this->wasExceptionThrown = true;
  44. }
  46. public function onTerminate()
  47. {
  48. if ((!$this->container->has('mailer') && !$this->container->has('swiftmailer.mailer.default')) || $this->wasExceptionThrown) {
  49. return;
  50. }
  51. $mailers = array_keys($this->container->getParameter('swiftmailer.mailers'));
  52. foreach ($mailers as $name) {
  53. if (method_exists($this->container, 'initialized') ? $this->container->initialized(sprintf('swiftmailer.mailer.%s', $name)) : true) {
  54. if ($this->container->getParameter(sprintf('swiftmailer.mailer.%s.spool.enabled', $name))) {
  55. $mailer = $this->container->get(sprintf('swiftmailer.mailer.%s', $name));
  56. $transport = $mailer->getTransport();
  57. if ($transport instanceof \Swift_Transport_SpoolTransport) {
  58. $spool = $transport->getSpool();
  59. if ($spool instanceof \Swift_MemorySpool) {
  60. try {
  61. $spool->flushQueue($this->container->get(sprintf('swiftmailer.mailer.%s.transport.real', $name)));
  62. } catch (\Swift_TransportException $exception) {
  63. if (null !== $this->logger) {
  64. $this->logger->error(sprintf('Exception occurred while flushing email queue: %s', $exception->getMessage()));
  65. }
  66. }
  67. }
  68. }
  69. }
  70. }
  71. }
  72. }
  74. public static function getSubscribedEvents()
  75. {
  76. $listeners = [
  77. KernelEvents::EXCEPTION => 'onException',
  78. KernelEvents::TERMINATE => 'onTerminate',
  79. ];
  81. if (class_exists('Symfony\Component\Console\ConsoleEvents')) {
  82. $listeners[class_exists('Symfony\Component\Console\Event\ConsoleErrorEvent') ? ConsoleEvents::ERROR : ConsoleEvents::EXCEPTION] = 'onException';
  83. $listeners[ConsoleEvents::TERMINATE] = 'onTerminate';
  84. }
  86. return $listeners;
  87. }
  89. public function reset()
  90. {
  91. $this->wasExceptionThrown = false;
  92. }
  93. }