symfony
diff --git a/‎src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.php
Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.php
+4Lines changed: 4 additions & 0 deletions b/‎src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.php
Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/Resources/config/messenger.php
+4Lines changed: 4 additions & 0 deletions
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/EventListener/StopWorkerOnCustomStopExceptionListener.php
Copy file name to clipboard
+56Lines changed: 56 additions & 0 deletions b/‎src/Symfony/Component/Messenger/EventListener/StopWorkerOnCustomStopExceptionListener.php
Copy file name to clipboard
+56Lines changed: 56 additions & 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/Exception/StopWorkerExceptionInterface.php
Copy file name to clipboard
+19Lines changed: 19 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Exception/StopWorkerExceptionInterface.php
Copy file name to clipboard
+19Lines changed: 19 additions & 0 deletions
@@ -19,6 +19,7 @@
 use Symfony\Component\Messenger\EventListener\DispatchPcntlSignalListener;
 use Symfony\Component\Messenger\EventListener\SendFailedMessageForRetryListener;
 use Symfony\Component\Messenger\EventListener\SendFailedMessageToFailureTransportListener;
+use Symfony\Component\Messenger\EventListener\StopWorkerOnCustomStopExceptionListener;
 use Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener;
 use Symfony\Component\Messenger\EventListener\StopWorkerOnSigtermSignalListener;
 use Symfony\Component\Messenger\Middleware\AddBusNameStampMiddleware;
@@ -186,6 +187,9 @@
         ->set('messenger.listener.stop_worker_on_sigterm_signal_listener', StopWorkerOnSigtermSignalListener::class)
             ->tag('kernel.event_subscriber')
 
+        ->set('messenger.listener.stop_worker_on_stop_exception_listener', StopWorkerOnCustomStopExceptionListener::class)
+            ->tag('kernel.event_subscriber')
+
         ->set('messenger.routable_message_bus', RoutableMessageBus::class)
             ->args([
                 abstract_arg('message bus locator'),
 
@@ -5,6 +5,7 @@ CHANGELOG
 -----
 
  * `InMemoryTransport` can perform message serialization through dsn `in-memory://?serialize=true`.
+ * Add `StopWorkerExceptionInterface` and its implementation `StopWorkerException` to stop the worker.
 
 5.2.0
 -----
 
@@ -0,0 +1,56 @@
+<?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\EventListener;
+
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
+use Symfony\Component\Messenger\Event\WorkerRunningEvent;
+use Symfony\Component\Messenger\Exception\HandlerFailedException;
+use Symfony\Component\Messenger\Exception\StopWorkerExceptionInterface;
+
+/**
+ * @author Grégoire Pineau <lyrixx@lyrixx.info>
+ */
+class StopWorkerOnCustomStopExceptionListener implements EventSubscriberInterface
+{
+    private $stop = false;
+
+    public function onMessageFailed(WorkerMessageFailedEvent $event): void
+    {
+        $th = $event->getThrowable();
+        if ($th instanceof StopWorkerExceptionInterface) {
+            $this->stop = true;
+        }
+        if ($th instanceof HandlerFailedException) {
+            foreach ($th->getNestedExceptions() as $e) {
+                if ($e instanceof StopWorkerExceptionInterface) {
+                    $this->stop = true;
+                }
+            }
+        }
+    }
+
+    public function onWorkerRunning(WorkerRunningEvent $event): void
+    {
+        if ($this->stop) {
+            $event->getWorker()->stop();
+        }
+    }
+
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            WorkerMessageFailedEvent::class => 'onMessageFailed',
+            WorkerRunningEvent::class => 'onWorkerRunning',
+        ];
+    }
+}
@@ -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 implements StopWorkerExceptionInterface
+{
+    public function __construct(string $message = 'Worker should stop.', ?\Throwable $previous = null)
+    {
+        parent::__construct($message, 0, $previous);
+    }
+}
@@ -0,0 +1,19 @@
+<?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>
+ */
+interface StopWorkerExceptionInterface extends \Throwable
+{
+}