From 9a45ae021e7fd48a6efc6b58f4d108becb916318 Mon Sep 17 00:00:00 2001 From: HypeMC Date: Tue, 25 Jul 2023 00:51:03 +0200 Subject: [PATCH] [FrameworkBundle] Fix using messenger 7.0 --- .../DependencyInjection/FrameworkExtension.php | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php b/src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php index 2b9981d46db44..56242bf318de7 100644 --- a/src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php +++ b/src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php @@ -111,6 +111,7 @@ use Symfony\Component\Messenger\Attribute\AsMessageHandler; use Symfony\Component\Messenger\Bridge as MessengerBridge; use Symfony\Component\Messenger\Command\StatsCommand; +use Symfony\Component\Messenger\EventListener\StopWorkerOnSignalsListener; use Symfony\Component\Messenger\Handler\BatchHandlerInterface; use Symfony\Component\Messenger\Handler\MessageHandlerInterface; use Symfony\Component\Messenger\MessageBus; @@ -2109,7 +2110,9 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder $container->getDefinition('messenger.transport.beanstalkd.factory')->addTag('messenger.transport_factory'); } - if ($config['stop_worker_on_signals']) { + if (!class_exists(StopWorkerOnSignalsListener::class)) { + $container->removeDefinition('messenger.listener.stop_worker_signals_listener'); + } elseif ($config['stop_worker_on_signals']) { $container->getDefinition('messenger.listener.stop_worker_signals_listener')->replaceArgument(0, $config['stop_worker_on_signals']); }