$container->
getParameterBag()->
remove($busMiddlewareParameter);
} if ($container->
hasDefinition('data_collector.messenger'
)) { $this->
registerBusToCollector($container,
$busId);
} } if ($container->
hasDefinition('messenger.receiver_locator'
)) { $this->
registerReceivers($container,
$busIds);
} $this->
registerHandlers($container,
$busIds);
} private function registerHandlers(ContainerBuilder
$container, array
$busIds): void
{ $definitions =
[];
$handlersByBusAndMessage =
[];
$handlerToOriginalServiceIdMapping =
[];
foreach ($container->
findTaggedServiceIds('messenger.message_handler', true
) as $serviceId =>
$tags) { foreach ($tags as $tag) { if (isset($tag['bus'
]) && !\
in_array($tag['bus'
],
$busIds, true
)) {