From 5e56dbfcfcaad271f12c07e5cf0ca15b7862c80e Mon Sep 17 00:00:00 2001
From: Borja Abad <borja@abadmonge.com>
Date: Fri, 29 Nov 2024 13:19:44 +0100
Subject: [PATCH] Catch HandlerFailedExceptions on InMemorySymfonyQueryBus.php
Signed-off-by: Borja Abad <borja@abadmonge.com>
---
.../Infrastructure/Bus/Query/InMemorySymfonyQueryBus.php | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/src/Shared/Infrastructure/Bus/Query/InMemorySymfonyQueryBus.php b/src/Shared/Infrastructure/Bus/Query/InMemorySymfonyQueryBus.php
index 4812214d0..a7a4a5b3a 100644
--- a/src/Shared/Infrastructure/Bus/Query/InMemorySymfonyQueryBus.php
+++ b/src/Shared/Infrastructure/Bus/Query/InMemorySymfonyQueryBus.php
@@ -8,6 +8,7 @@
use CodelyTv\Shared\Domain\Bus\Query\QueryBus;
use CodelyTv\Shared\Domain\Bus\Query\Response;
use CodelyTv\Shared\Infrastructure\Bus\CallableFirstParameterExtractor;
+use Symfony\Component\Messenger\Exception\HandlerFailedException;
use Symfony\Component\Messenger\Exception\NoHandlerForMessageException;
use Symfony\Component\Messenger\Handler\HandlersLocator;
use Symfony\Component\Messenger\MessageBus;
@@ -36,6 +37,8 @@ public function ask(Query $query): ?Response
return $stamp->getResult();
} catch (NoHandlerForMessageException) {
throw new QueryNotRegisteredError($query);
- }
+ } catch (HandlerFailedException $error) {
+ throw $error->getPrevious() ?? $error;
+ }
}
}