Skip to content

Commit 37920e1

Browse files
committed
Change the moved pass to match the expected arguments
1 parent 3833f88 commit 37920e1

File tree

3 files changed

+5
-1
lines changed

3 files changed

+5
-1
lines changed

src/Symfony/Bundle/FrameworkBundle/DependencyInjection/Compiler/MessengerCommandsPass.php

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
namespace Symfony\Bundle\FrameworkBundle\DependencyInjection\Compiler;
1313

1414
use Symfony\Component\DependencyInjection\Compiler\CompilerPassInterface;
15+
use Symfony\Component\DependencyInjection\Compiler\ServiceLocatorTagPass;
1516
use Symfony\Component\DependencyInjection\ContainerBuilder;
1617
use Symfony\Component\DependencyInjection\Reference;
1718
use Symfony\Component\Messenger\DependencyInjection\MessengerPass;
@@ -37,7 +38,9 @@ public function process(ContainerBuilder $container)
3738

3839
$container
3940
->getDefinition('console.command.messenger_consume_messages')
41+
->replaceArgument(0, ServiceLocatorTagPass::register($container, $buses))
4042
->replaceArgument(3, $this->findReceiverNames($container))
43+
->replaceArgument(4, array_keys($buses))
4144
;
4245
}
4346

src/Symfony/Bundle/FrameworkBundle/Resources/config/console.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@
7373
<argument /> <!-- Message bus locator -->
7474
<argument type="service" id="messenger.receiver_locator" />
7575
<argument type="service" id="logger" on-invalid="null" />
76-
<argument>null</argument> <!-- Default receiver name -->
76+
<argument type="collection" /> <!-- Receiver names -->
7777
<argument type="collection" /> <!-- Message bus names -->
7878

7979
<tag name="console.command" command="messenger:consume-messages" />

src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/Compiler/MessengerCommandsPassTest.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,5 +40,6 @@ public function testItRegistersMultipleReceiversAndSetsTheReceiverNamesOnTheComm
4040
(new MessengerCommandsPass())->process($container);
4141

4242
$this->assertSame(array('amqp', 'dummy'), $container->getDefinition('console.command.messenger_consume_messages')->getArgument(3));
43+
$this->assertSame(array('my_bus_name'), $container->getDefinition('console.command.messenger_consume_messages')->getArgument(4));
4344
}
4445
}

0 commit comments

Comments
 (0)