symfony
diff --git a/‎src/Symfony/Component/Messenger/CHANGELOG.md
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/CHANGELOG.md
+1Lines changed: 1 addition & 0 deletions b/‎src/Symfony/Component/Messenger/CHANGELOG.md
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/CHANGELOG.md
+1Lines changed: 1 addition & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Exception/StopWorkerException.php
Copy file name to clipboard
+23Lines changed: 23 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Exception/StopWorkerException.php
Copy file name to clipboard
+23Lines changed: 23 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Worker.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Worker.php
+18-1Lines changed: 18 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Worker.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Worker.php
+18-1Lines changed: 18 additions & 1 deletion
@@ -5,6 +5,7 @@ CHANGELOG
 -----
 
  * `InMemoryTransport` can perform message serialization through dsn `in-memory://?serialize=true`.
+ * Add `StopWorkerException` to stop the worker.
 
 5.2.0
 -----
 
@@ -0,0 +1,23 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <fabien@symfony.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\Component\Messenger\Exception;
+
+/**
+ * @author Grégoire Pineau <lyrixx@lyrixx.info>
+ */
+class StopWorkerException extends RuntimeException
+{
+    public function __construct($message = "Worker should stop", ?\Throwable $previous = null)
+    {
+        parent::__construct($message, 0, $previous);
+    }
+}
@@ -22,6 +22,7 @@
 use Symfony\Component\Messenger\Event\WorkerStoppedEvent;
 use Symfony\Component\Messenger\Exception\HandlerFailedException;
 use Symfony\Component\Messenger\Exception\RejectRedeliveredMessageException;
+use Symfony\Component\Messenger\Exception\StopWorkerException;
 use Symfony\Component\Messenger\Stamp\ConsumedByWorkerStamp;
 use Symfony\Component\Messenger\Stamp\ReceivedStamp;
 use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
@@ -113,6 +114,18 @@ private function handleMessage(Envelope $envelope, ReceiverInterface $receiver,
         try {
             $envelope = $this->bus->dispatch($envelope->with(new ReceivedStamp($transportName), new ConsumedByWorkerStamp()));
         } catch (\Throwable $throwable) {
+            if ($throwable instanceof StopWorkerException) {
+                $this->stop();
+            }
+            if ($throwable instanceof HandlerFailedException) {
+                foreach ($throwable->getNestedExceptions() as $e) {
+                    if ($e instanceof StopWorkerException) {
+                        $this->stop();
+                        break;
+                    }
+                }
+            }
+
             $rejectFirst = $throwable instanceof RejectRedeliveredMessageException;
             if ($rejectFirst) {
                 // redelivered messages are rejected first so that continuous failures in an event listener or while
@@ -162,6 +175,10 @@ private function dispatchEvent(object $event): void
             return;
         }
 
-        $this->eventDispatcher->dispatch($event);
+        try {
+            $this->eventDispatcher->dispatch($event);
+        } catch (StopWorkerException $e) {
+            $this->stop();
+        }
     }
 }