diff --git a/src/Symfony/Bundle/SwiftmailerBundle/Command/SendEmailCommand.php b/src/Symfony/Bundle/SwiftmailerBundle/Command/SendEmailCommand.php new file mode 100644 index 0000000000..a99a204870 --- /dev/null +++ b/src/Symfony/Bundle/SwiftmailerBundle/Command/SendEmailCommand.php @@ -0,0 +1,62 @@ + + * + * For the full copyright and license information, please view the LICENSE + * file that was distributed with this source code. + */ + +namespace Symfony\Bundle\SwiftmailerBundle\Command; + +use Symfony\Bundle\FrameworkBundle\Command\Command; +use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Output\OutputInterface; +use Symfony\Component\Console\Input\InputOption; + +/** + * Warmup the cache. + * + * @author Fabien Potencier + * @author Clément JOBEILI + */ +class SendEmailCommand extends Command +{ + /** + * @see Command + */ + protected function configure() + { + $this + ->setName('swiftmailer:spool:send') + ->setDescription('Send all emails from the spool') + ->addOption('message-limit', 0, InputOption::VALUE_OPTIONAL, 'The maximum number of messages to send.') + ->addOption('time-limit', 0, InputOption::VALUE_OPTIONAL, 'The time limit for sending messages (in seconds).') + ->setHelp(<<swiftmailer:spool:send command send all emails from the spool. + +EOF + ) + ; + } + + /** + * {@inheritdoc} + */ + protected function execute(InputInterface $input, OutputInterface $output) + { + $mailer = $this->container->get('mailer'); + $transport = $mailer->getTransport(); + + if ("Swift_Transport_SpoolTransport" === get_class($transport)) { + $spool = $transport->getSpool(); + $spool->setMessageLimit($input->getOption('message-limit')); + $spool->setTimeLimit($input->getOption('time-limit')); + $sent = $spool->flushQueue($this->container->get('swiftmailer.transport.real')); + + $output->writeln(sprintf('sent %s emails', $sent)); + } + } +}