forward a Clock instance to the created InMemoryTransport

symfony · Apr 13, 2024 · 9e7087c · 9e7087c
1 parent 1fca6b8
commit 9e7087c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,6 +4,7 @@ CHANGELOG
 7.1
 ---
 
+ * `InMemoryTransportFactory` creates the `InMemoryTransport` with a clock (if configured in the factory)
  * Add option `redis_sentinel` as an alias for `sentinel_master`
  * Add `--all` option to the `messenger:consume` command
  * Add parameter `$jitter` to `MultiplierRetryStrategy` in order to randomize delay and prevent the thundering herd effect

diff --git a/Transport/InMemory/InMemoryTransportFactory.php b/Transport/InMemory/InMemoryTransportFactory.php
@@ -11,6 +11,7 @@
 
 namespace Symfony\Component\Messenger\Transport\InMemory;
 
+use Psr\Clock\ClockInterface;
 use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
 use Symfony\Component\Messenger\Transport\TransportFactoryInterface;
 use Symfony\Component\Messenger\Transport\TransportInterface;
@@ -28,11 +29,16 @@ class InMemoryTransportFactory implements TransportFactoryInterface, ResetInterf
      */
     private array $createdTransports = [];
 
+    public function __construct(
+        private readonly ?ClockInterface $clock = null,
+    ) {
+    }
+
     public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
     {
         ['serialize' => $serialize] = $this->parseDsn($dsn);
 
-        return $this->createdTransports[] = new InMemoryTransport($serialize ? $serializer : null);
+        return $this->createdTransports[] = new InMemoryTransport($serialize ? $serializer : null, $this->clock);
     }
 
     public function supports(string $dsn, array $options): bool