在我目前正在工作的当前项目中,我有一个symfony任务,它将一些海量数据插入数据库并运行至少半小时. 当任务开始正确发送邮件通知时,问题是在执行任务时我们无法发送另一封邮件来通
当任务开始正确发送邮件通知时,问题是在执行任务时我们无法发送另一封邮件来通知处理结束.
邮件工厂当前配置了线程传送策略,但在这种特定情况下,我们希望使用sendNextImmediately()方法立即触发通知.
我正在获得例外:
[Swift_TransportException]
Expected response code 250 but got code “451”, with message “451 4.4.2 Timeout – closing connection. 74sm1186065wem.17
”
以及php日志文件中的流动错误:
Warning: fwrite(): SSL: Broken pipe in /var/www/project/lib/vendor/symfony/lib/vendor/swiftmailer/classes/Swift/Transport/StreamBuffer.php on line 209
有人能帮忙吗?
有什么方法可以刷新symfony邮件来建立新的连接?
我们发现以下代码完成了这项工作:
private function sendEmailMessage($renderedTemplate, $subject, $toEmail)
{
$mailer = $this->getContainer()->get('mailer');
/* @var $mailer \Swift_Mailer */
if(!$mailer->getTransport()->isStarted()){
$mailer->getTransport()->start();
}
$sendException = null;
/* @var $message \Swift_Message */
$message = \Swift_Message::newInstance()
->setSubject($subject)
->setFrom($this->getContainer()->getParameter('email_from'))
->setTo($toEmail)
->setBody($renderedTemplate);
$mailer->send($message);
$mailer->getTransport()->stop();
//throw $sendException;
}
