[Messenger] add handler description as array key to HandlerFailedException::getNestedExceptions()

kbond · kbond · commit 97e3feaa37bb · 2023-08-09T13:38:59.000-04:00
diff --git a/src/Symfony/Component/Messenger/CHANGELOG.md b/src/Symfony/Component/Messenger/CHANGELOG.md
@@ -6,6 +6,7 @@ CHANGELOG
 
  * Deprecate `StopWorkerOnSignalsListener` in favor of using the `SignalableCommandInterface`
  * Add `HandlerDescriptor::getOptions`
+ * Add handler description as array key to `HandlerFailedException::getNestedExceptions()`
 
 6.3
 ---
diff --git a/src/Symfony/Component/Messenger/Exception/HandlerFailedException.php b/src/Symfony/Component/Messenger/Exception/HandlerFailedException.php
@@ -19,7 +19,7 @@ class HandlerFailedException extends RuntimeException
     private Envelope $envelope;
 
     /**
-     * @param \Throwable[] $exceptions
+     * @param array<string,\Throwable> $exceptions
      */
     public function __construct(Envelope $envelope, array $exceptions)
     {
@@ -46,7 +46,7 @@ public function getEnvelope(): Envelope
     }
 
     /**
-     * @return \Throwable[]
+     * @return array<string,\Throwable>
      */
     public function getNestedExceptions(): array
     {
diff --git a/src/Symfony/Component/Messenger/Middleware/HandleMessageMiddleware.php b/src/Symfony/Component/Messenger/Middleware/HandleMessageMiddleware.php
@@ -95,7 +95,7 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope
                 $envelope = $envelope->with($handledStamp);
                 $this->logger?->info('Message {class} handled by {handler}', $context + ['handler' => $handledStamp->getHandlerName()]);
             } catch (\Throwable $e) {
-                $exceptions[] = $e;
+                $exceptions[$handlerDescriptor->getName()] = $e;
             }
         }
 
@@ -107,7 +107,7 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope
                     $handler = $stamp->getHandlerDescriptor()->getBatchHandler();
                     $handler->flush($flushStamp->force());
                 } catch (\Throwable $e) {
-                    $exceptions[] = $e;
+                    $exceptions[$stamp->getHandlerDescriptor()->getName()] = $e;
                 }
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ class HandlerFailedException extends RuntimeException`
`19`	`19`	`private Envelope $envelope;`
`20`	`20`
`21`	`21`	`/**`
`22`		`- * @param \Throwable[] $exceptions`
	`22`	`+ * @param array<string,\Throwable> $exceptions`
`23`	`23`	`*/`
`24`	`24`	`public function __construct(Envelope $envelope, array $exceptions)`
`25`	`25`	`{`
`@@ -46,7 +46,7 @@ public function getEnvelope(): Envelope`
`46`	`46`	`}`
`47`	`47`
`48`	`48`	`/**`
`49`		`- * @return \Throwable[]`
	`49`	`+ * @return array<string,\Throwable>`
`50`	`50`	`*/`
`51`	`51`	`public function getNestedExceptions(): array`
`52`	`52`	`{`
Original file line number	Diff line number	Diff line change
`@@ -95,7 +95,7 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope`
`95`	`95`	`$envelope = $envelope->with($handledStamp);`
`96`	`96`	`$this->logger?->info('Message {class} handled by {handler}', $context + ['handler' => $handledStamp->getHandlerName()]);`
`97`	`97`	`} catch (\Throwable $e) {`
`98`		`- $exceptions[] = $e;`
	`98`	`+ $exceptions[$handlerDescriptor->getName()] = $e;`
`99`	`99`	`}`
`100`	`100`	`}`
`101`	`101`
`@@ -107,7 +107,7 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope`
`107`	`107`	`$handler = $stamp->getHandlerDescriptor()->getBatchHandler();`
`108`	`108`	`$handler->flush($flushStamp->force());`
`109`	`109`	`} catch (\Throwable $e) {`
`110`		`- $exceptions[] = $e;`
	`110`	`+ $exceptions[$stamp->getHandlerDescriptor()->getName()] = $e;`
`111`	`111`	`}`
`112`	`112`	`}`
`113`	`113`	`}`