vendor/symfony/symfony/src/Symfony/Bridge/Monolog/Handler/SwiftMailerHandler.php line 45

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\Bridge\Monolog\Handler;
  14. use Monolog\Handler\SwiftMailerHandler as BaseSwiftMailerHandler;
  15. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  16. use Symfony\Component\HttpKernel\Event\PostResponseEvent;
  18. /**
  19.  * Extended SwiftMailerHandler that flushes mail queue if necessary.
  20.  *
  21.  * @author Philipp Kräutli <pkraeutli@astina.ch>
  22.  */
  23. class SwiftMailerHandler extends BaseSwiftMailerHandler
  24. {
  25.     protected $transport;
  27.     protected $instantFlush = false;
  29.     public function setTransport(\Swift_Transport $transport)
  30.     {
  31.         $this->transport = $transport;
  32.     }
  34.     /**
  35.      * After the kernel has been terminated we will always flush messages.
  36.      */
  37.     public function onKernelTerminate(PostResponseEvent $event)
  38.     {
  39.         $this->instantFlush = true;
  40.     }
  42.     /**
  43.      * After the CLI application has been terminated we will always flush messages.
  44.      */
  45.     public function onCliTerminate(ConsoleTerminateEvent $event)
  46.     {
  47.         $this->instantFlush = true;
  48.     }
  50.     /**
  51.      * {@inheritdoc}
  52.      */
  53.     protected function send($content, array $records)
  54.     {
  55.         parent::send($content, $records);
  57.         if ($this->instantFlush) {
  58.             $this->flushMemorySpool();
  59.         }
  60.     }
  62.     /**
  63.      * {@inheritdoc}
  64.      */
  65.     public function reset()
  66.     {
  67.         $this->flushMemorySpool();
  68.     }
  70.     /**
  71.      * Flushes the mail queue if a memory spool is used.
  72.      */
  73.     private function flushMemorySpool()
  74.     {
  75.         $mailerTransport = $this->mailer->getTransport();
  76.         if (!$mailerTransport instanceof \Swift_Transport_SpoolTransport) {
  77.             return;
  78.         }
  80.         $spool = $mailerTransport->getSpool();
  81.         if (!$spool instanceof \Swift_MemorySpool) {
  82.             return;
  83.         }
  85.         if (null === $this->transport) {
  86.             throw new \Exception('No transport available to flush mail queue');
  87.         }
  89.         $spool->flushQueue($this->transport);
  90.     }
  91. }