Skip to content

Commit 9a45ae0

Browse files
committed
[FrameworkBundle] Fix using messenger 7.0
1 parent 47b95f2 commit 9a45ae0

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,7 @@
111111
use Symfony\Component\Messenger\Attribute\AsMessageHandler;
112112
use Symfony\Component\Messenger\Bridge as MessengerBridge;
113113
use Symfony\Component\Messenger\Command\StatsCommand;
114+
use Symfony\Component\Messenger\EventListener\StopWorkerOnSignalsListener;
114115
use Symfony\Component\Messenger\Handler\BatchHandlerInterface;
115116
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
116117
use Symfony\Component\Messenger\MessageBus;
@@ -2109,7 +2110,9 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
21092110
$container->getDefinition('messenger.transport.beanstalkd.factory')->addTag('messenger.transport_factory');
21102111
}
21112112

2112-
if ($config['stop_worker_on_signals']) {
2113+
if (!class_exists(StopWorkerOnSignalsListener::class)) {
2114+
$container->removeDefinition('messenger.listener.stop_worker_signals_listener');
2115+
} elseif ($config['stop_worker_on_signals']) {
21132116
$container->getDefinition('messenger.listener.stop_worker_signals_listener')->replaceArgument(0, $config['stop_worker_on_signals']);
21142117
}
21152118

0 commit comments

Comments
 (0)