Commitcc9a246

Robin Chalas

committed

[Messenger] Fix incompatibility with FrameworkBundle <4.3.1

1 parentd7d6d92 commitcc9a246Copy full SHA for cc9a246

File tree

-4

lines changed

src/Symfony
- Bundle/FrameworkBundle/Resources/config
  - console.xml
- Component/Messenger/DependencyInjection
  - MessengerPass.php

-4

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@`
`82`	`82`	`</service>`
`83`	`83`
`84`	`84`	`<serviceid="console.command.messenger_consume_messages"class="Symfony\Component\Messenger\Command\ConsumeMessagesCommand">`
`85`		`- <argumenttype="service"id="messenger.routable_message_bus" />`
	`85`	`+ <argument/><!-- Routable message bus-->`
`86`	`86`	`<argumenttype="service"id="messenger.receiver_locator" />`
`87`	`87`	`<argumenttype="service"id="logger"on-invalid="null" />`
`88`	`88`	`<argumenttype="collection" /><!-- Receiver names-->`

Lines changed: 8 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -253,14 +253,19 @@ private function registerReceivers(ContainerBuilder $container, array $busIds)`
`253`	`253`	`$buses[$busId] =newReference($busId);`
`254`	`254`	`}`
`255`	`255`
`256`		`-if ($container->hasDefinition('messenger.routable_message_bus')) {`
	`256`	`+if ($hasRoutableMessageBus =$container->hasDefinition('messenger.routable_message_bus')) {`
`257`	`257`	`$container->getDefinition('messenger.routable_message_bus')`
`258`	`258`	`->replaceArgument(0, ServiceLocatorTagPass::register($container,$buses));`
`259`	`259`	`}`
`260`	`260`
`261`	`261`	`if ($container->hasDefinition('console.command.messenger_consume_messages')) {`
`262`		`-$container->getDefinition('console.command.messenger_consume_messages')`
`263`		`- ->replaceArgument(3,array_values($receiverNames));`
	`262`	`+$consumeCommandDefinition =$container->getDefinition('console.command.messenger_consume_messages');`
	`263`	`+`
	`264`	`+if ($hasRoutableMessageBus) {`
	`265`	`+$consumeCommandDefinition->replaceArgument(0,'messenger.routable_message_bus');`
	`266`	`+ }`
	`267`	`+`
	`268`	`+$consumeCommandDefinition->replaceArgument(3,array_values($receiverNames));`
`264`	`269`	`}`
`265`	`270`
`266`	`271`	`if ($container->hasDefinition('console.command.messenger_setup_transports')) {`

Comments

(0)