Skip to content

Commit 682369c

Browse files
Merge branch '6.3' into 6.4
* 6.3: fix #51235 - fix the order of merging of serializationContext and self::CONTEXT_DENORMALIZE [HttpClient] Fix Static Code Analyzer issue with JsonMockResponse [Messenger] Fix exiting `FailedMessagesRetryCommand` [Serializer] Fix reindex normalizedData array in AbstractObjectNormalizer::denormalize() [Validator] Fix `File::$extensions`’ PHPDoc [Mime] Fix email (de)serialization issues [Serializer] Fix parsing XML root node attributes fix parsing of payload timestamp to DateTimeImmutable Fix routing to multiple fallback transports Fix missing stamps in delayed message handling [DoctrineBridge] Ignore invalid stores in `LockStoreSchemaListener` raised by `StoreFactory`
2 parents 83597b5 + 567cafc commit 682369c

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

DependencyInjection/FrameworkExtension.php

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2122,6 +2122,16 @@ private function registerMessengerConfiguration(array $config, ContainerBuilder
21222122
$container->getDefinition('messenger.transport.beanstalkd.factory')->addTag('messenger.transport_factory');
21232123
}
21242124

2125+
if ($config['stop_worker_on_signals'] && $this->hasConsole()) {
2126+
$container->getDefinition('console.command.messenger_consume_messages')
2127+
->replaceArgument(8, $config['stop_worker_on_signals']);
2128+
$container->getDefinition('console.command.messenger_failed_messages_retry')
2129+
->replaceArgument(6, $config['stop_worker_on_signals']);
2130+
}
2131+
2132+
if ($this->hasConsole() && $container->hasDefinition('messenger.listener.stop_worker_signals_listener')) {
2133+
$container->getDefinition('messenger.listener.stop_worker_signals_listener')->clearTag('kernel.event_subscriber');
2134+
}
21252135
if (!class_exists(StopWorkerOnSignalsListener::class)) {
21262136
$container->removeDefinition('messenger.listener.stop_worker_signals_listener');
21272137
} elseif ($config['stop_worker_on_signals']) {

Resources/config/console.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -165,6 +165,7 @@
165165
service('messenger.listener.reset_services')->nullOnInvalid(),
166166
[], // Bus names
167167
service('messenger.rate_limiter_locator')->nullOnInvalid(),
168+
null,
168169
])
169170
->tag('console.command')
170171
->tag('monolog.logger', ['channel' => 'messenger'])
@@ -196,6 +197,7 @@
196197
service('event_dispatcher'),
197198
service('logger')->nullOnInvalid(),
198199
service('messenger.transport.native_php_serializer')->nullOnInvalid(),
200+
null,
199201
])
200202
->tag('console.command')
201203
->tag('monolog.logger', ['channel' => 'messenger'])

0 commit comments

Comments
 (0)