full list of changes below:

- check if aggregate supports given command
- check if listener supports given query

Author: alanbem

src/Domain/Command/Handling.php

@@ -13,6 +13,7 @@
 
 namespace Streak\Domain\Command;
 
+use Streak\Domain\AggregateRoot;
 use Streak\Domain\Command;
 use Streak\Domain\Exception\CommandNotSupported;
 
@@ -25,6 +26,12 @@ trait Handling
 {
     public function handleCommand(Command $command): void
     {
+        if ($command instanceof AggregateRootCommand && $this instanceof AggregateRoot) {
+            if (false === $this->aggregateRootId()->equals($command->aggregateRootId())) {
+                throw new CommandNotSupported($command);
+            }
+        }
+
         $reflection = new \ReflectionObject($this);
 
         foreach ($reflection->getMethods() as $method) {

src/Domain/Query/Handling.php

@@ -13,6 +13,7 @@
 
 namespace Streak\Domain\Query;
 
+use Streak\Domain\Event;
 use Streak\Domain\Exception\QueryNotSupported;
 use Streak\Domain\Query;
 
@@ -25,6 +26,12 @@ trait Handling
 {
     public function handleQuery(Query $query)
     {
+        if ($query instanceof EventListenerQuery && $this instanceof Event\Listener) {
+            if (false === $this->listenerId()->equals($query->listenerId())) {
+                throw new QueryNotSupported($query);
+            }
+        }
+
         $reflection = new \ReflectionObject($this);
 
         foreach ($reflection->getMethods() as $method) {