Added stamps to the QueryBus

68publishers · Mar 1, 2024 · 094df48 · 094df48
1 parent 3e76114
commit 094df48
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/src/ArchitectureBundle/Bridge/Symfony/Messenger/Bus/QueryBus.php b/src/ArchitectureBundle/Bridge/Symfony/Messenger/Bus/QueryBus.php
@@ -6,6 +6,7 @@
 
 use SixtyEightPublishers\ArchitectureBundle\Bus\QueryBusInterface;
 use SixtyEightPublishers\ArchitectureBundle\ReadModel\Query\QueryInterface;
+use Symfony\Component\Messenger\Envelope;
 use Symfony\Component\Messenger\HandleTrait;
 use Symfony\Component\Messenger\MessageBusInterface;
 
@@ -18,8 +19,13 @@ public function __construct(MessageBusInterface $messageBus)
         $this->messageBus = $messageBus;
     }
 
-    public function dispatch(QueryInterface $message): mixed
+    public function dispatch(QueryInterface $message, array $stamps = []): mixed
     {
-        return $this->handle($message);
+        $envelope = new Envelope(
+            message: $message,
+            stamps: $stamps,
+        );
+
+        return $this->handle($envelope);
     }
 }
diff --git a/src/ArchitectureBundle/Bus/CommandBusInterface.php b/src/ArchitectureBundle/Bus/CommandBusInterface.php
@@ -10,7 +10,7 @@
 interface CommandBusInterface
 {
     /**
-     * @param StampInterface[] $stamps
+     * @param array<int, StampInterface> $stamps
      */
     public function dispatch(CommandInterface $message, array $stamps = []): void;
 }
diff --git a/src/ArchitectureBundle/Bus/QueryBusInterface.php b/src/ArchitectureBundle/Bus/QueryBusInterface.php
@@ -5,8 +5,12 @@
 namespace SixtyEightPublishers\ArchitectureBundle\Bus;
 
 use SixtyEightPublishers\ArchitectureBundle\ReadModel\Query\QueryInterface;
+use Symfony\Component\Messenger\Stamp\StampInterface;
 
 interface QueryBusInterface
 {
-    public function dispatch(QueryInterface $message): mixed;
+    /**
+     * @param array<int, StampInterface> $stamps
+     */
+    public function dispatch(QueryInterface $message, array $stamps = []): mixed;
 }