123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293 |
- <?php
- /*
- * This file is part of the Symfony package.
- *
- * (c) Fabien Potencier <fabien@symfony.com>
- *
- * For the full copyright and license information, please view the LICENSE
- * file that was distributed with this source code.
- */
- namespace Symfony\Bridge\Monolog\Handler;
- use Monolog\Handler\SwiftMailerHandler as BaseSwiftMailerHandler;
- use Symfony\Component\Console\Event\ConsoleTerminateEvent;
- use Symfony\Component\HttpKernel\Event\TerminateEvent;
- /**
- * Extended SwiftMailerHandler that flushes mail queue if necessary.
- *
- * @author Philipp Kräutli <pkraeutli@astina.ch>
- *
- * @final
- */
- class SwiftMailerHandler extends BaseSwiftMailerHandler
- {
- protected $transport;
- protected $instantFlush = false;
- public function setTransport(\Swift_Transport $transport)
- {
- $this->transport = $transport;
- }
- /**
- * After the kernel has been terminated we will always flush messages.
- */
- public function onKernelTerminate(TerminateEvent $event)
- {
- $this->instantFlush = true;
- }
- /**
- * After the CLI application has been terminated we will always flush messages.
- */
- public function onCliTerminate(ConsoleTerminateEvent $event)
- {
- $this->instantFlush = true;
- }
- /**
- * {@inheritdoc}
- */
- protected function send($content, array $records): void
- {
- parent::send($content, $records);
- if ($this->instantFlush) {
- $this->flushMemorySpool();
- }
- }
- /**
- * {@inheritdoc}
- */
- public function reset(): void
- {
- $this->flushMemorySpool();
- }
- /**
- * Flushes the mail queue if a memory spool is used.
- */
- private function flushMemorySpool()
- {
- $mailerTransport = $this->mailer->getTransport();
- if (!$mailerTransport instanceof \Swift_Transport_SpoolTransport) {
- return;
- }
- $spool = $mailerTransport->getSpool();
- if (!$spool instanceof \Swift_MemorySpool) {
- return;
- }
- if (null === $this->transport) {
- throw new \Exception('No transport available to flush mail queue.');
- }
- $spool->flushQueue($this->transport);
- }
- }
|