Workaround, waiting for symfony/swiftmailer-bundle#64 to be merged

Author: BitOne

Command/BatchCommand.php

@@ -137,6 +137,10 @@ protected function execute(InputInterface $input, OutputInterface $output)
                 )
             );
         }
+
+        // FIXME: Workaround, waiting for https://github.com/symfony/SwiftmailerBundle/pull/64
+        // to be merged
+        $this->flushMailQueue();
     }
 
     /**
@@ -208,4 +212,35 @@ private function decodeConfiguration($data)
 
         throw new \InvalidArgumentException($error);
     }
+
+    /**
+     * @see Symfony\Bundle\SwiftmailerBundle\EventListener\EmailSenderListener::onKernelTerminate
+     * and https://github.com/symfony/SwiftmailerBundle/pull/64
+     */
+    public function flushMailQueue()
+    {
+       if (!$this->getContainer()->has('mailer')) {
+            return;
+        }
+
+        $mailers = array_keys($this->getContainer()->getParameter('swiftmailer.mailers'));
+        foreach ($mailers as $name) {
+            if ($this->getContainer() instanceof IntrospectableContainerInterface ?
+                $this->getContainer()->initialized(sprintf('swiftmailer.mailer.%s', $name)) : true) {
+                if ($this->getContainer()->getParameter(sprintf('swiftmailer.mailer.%s.spool.enabled', $name))) {
+                    $mailer = $this->getContainer()->get(sprintf('swiftmailer.mailer.%s', $name));
+                    $transport = $mailer->getTransport();
+                    if ($transport instanceof \Swift_Transport_SpoolTransport) {
+                        $spool = $transport->getSpool();
+                        if ($spool instanceof \Swift_MemorySpool) {
+                            $spool->flushQueue(
+                                $this->getContainer()->get(sprintf('swiftmailer.mailer.%s.transport.real', $name))
+                            );
+                        }
+                    }
+                }
+            }
+        }
+ 
+    }
 }