[Notifier] Dispatch message event in null transport

jschaedl · jschaedl · commit 3809d90fba57 · 2020-02-24T09:57:01.000+01:00
diff --git a/src/Symfony/Component/Notifier/Transport/NullTransport.php b/src/Symfony/Component/Notifier/Transport/NullTransport.php
@@ -11,7 +11,10 @@
 
 namespace Symfony\Component\Notifier\Transport;
 
+use Symfony\Component\EventDispatcher\LegacyEventDispatcherProxy;
+use Symfony\Component\Notifier\Event\MessageEvent;
 use Symfony\Component\Notifier\Message\MessageInterface;
+use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
 
 /**
  * @author Fabien Potencier <fabien@symfony.com>
@@ -20,8 +23,18 @@
  */
 class NullTransport implements TransportInterface
 {
+    private $dispatcher;
+
+    public function __construct(EventDispatcherInterface $dispatcher = null)
+    {
+        $this->dispatcher = LegacyEventDispatcherProxy::decorate($dispatcher);
+    }
+
     public function send(MessageInterface $message): void
     {
+        if (null !== $this->dispatcher) {
+            $this->dispatcher->dispatch(new MessageEvent($message));
+        }
     }
 
     public function __toString(): string
diff --git a/src/Symfony/Component/Notifier/Transport/NullTransportFactory.php b/src/Symfony/Component/Notifier/Transport/NullTransportFactory.php
@@ -26,7 +26,7 @@ final class NullTransportFactory extends AbstractTransportFactory
     public function create(Dsn $dsn): TransportInterface
     {
         if ('null' === $dsn->getScheme()) {
-            return new NullTransport();
+            return new NullTransport($this->dispatcher);
         }
 
         throw new UnsupportedSchemeException($dsn, 'null', $this->getSupportedSchemes());

Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,7 @@ final class NullTransportFactory extends AbstractTransportFactory`
`26`	`26`	`public function create(Dsn $dsn): TransportInterface`
`27`	`27`	`{`
`28`	`28`	`if ('null' === $dsn->getScheme()) {`
`29`		`- return new NullTransport();`
	`29`	`+ return new NullTransport($this->dispatcher);`
`30`	`30`	`}`
`31`	`31`
`32`	`32`	`throw new UnsupportedSchemeException($dsn, 'null', $this->getSupportedSchemes());`