multi client configuration

Author: ASKozienko

pkg/enqueue/Symfony/Consumption/ConsumeCommand.php

@@ -27,19 +27,20 @@ class ConsumeCommand extends Command
     /**
      * @var string
      */
-    private $queueConsumerIdPattern;
+    private $defaultTransport;
 
     /**
-     * [name => QueueConsumerInterface].
-     *
-     * @param QueueConsumerInterface[]
+     * @var string
      */
-    public function __construct(ContainerInterface $container, string $queueConsumerIdPattern = 'enqueue.transport.%s.queue_consumer')
-    {
-        parent::__construct(static::$defaultName);
+    private $queueConsumerIdPattern;
 
+    public function __construct(ContainerInterface $container, string $defaultTransport, string $queueConsumerIdPattern = 'enqueue.transport.%s.queue_consumer')
+    {
         $this->container = $container;
+        $this->defaultTransport = $defaultTransport;
         $this->queueConsumerIdPattern = $queueConsumerIdPattern;
+
+        parent::__construct(static::$defaultName);
     }
 
     protected function configure(): void
@@ -49,7 +50,7 @@ protected function configure(): void
         $this->configureLoggerExtension();
 
         $this
-            ->addOption('transport', 't', InputOption::VALUE_OPTIONAL, 'The transport to consume messages from.', 'default')
+            ->addOption('transport', 't', InputOption::VALUE_OPTIONAL, 'The transport to consume messages from.', $this->defaultTransport)
             ->setDescription('A worker that consumes message from a broker. '.
                 'To use this broker you have to configure queue consumer before adding to the command')
         ;

pkg/enqueue/Tests/Symfony/Consumption/ConsumeCommandTest.php

@@ -28,19 +28,19 @@ public function testShouldNotBeFinal()
 
     public function testCouldBeConstructedWithRequiredAttributes()
     {
-        new ConsumeCommand($this->createMock(ContainerInterface::class));
+        new ConsumeCommand($this->createMock(ContainerInterface::class), 'default');
     }
 
     public function testShouldHaveCommandName()
     {
-        $command = new ConsumeCommand($this->createMock(ContainerInterface::class));
+        $command = new ConsumeCommand($this->createMock(ContainerInterface::class), 'default');
 
         $this->assertEquals('enqueue:transport:consume', $command->getName());
     }
 
     public function testShouldHaveExpectedOptions()
     {
-        $command = new ConsumeCommand($this->createMock(ContainerInterface::class));
+        $command = new ConsumeCommand($this->createMock(ContainerInterface::class), 'default');
 
         $options = $command->getDefinition()->getOptions();
 
@@ -56,7 +56,7 @@ public function testShouldHaveExpectedOptions()
 
     public function testShouldHaveExpectedAttributes()
     {
-        $command = new ConsumeCommand($this->createMock(ContainerInterface::class));
+        $command = new ConsumeCommand($this->createMock(ContainerInterface::class), 'default');
 
         $arguments = $command->getDefinition()->getArguments();
 
@@ -74,7 +74,7 @@ public function testShouldExecuteDefaultConsumption()
 
         $command = new ConsumeCommand(new Container([
             'enqueue.transport.default.queue_consumer' => $consumer,
-        ]));
+        ]), 'default');
 
         $tester = new CommandTester($command);
         $tester->execute([]);
@@ -98,7 +98,7 @@ public function testShouldExecuteCustomConsumption()
         $command = new ConsumeCommand(new Container([
             'enqueue.transport.default.queue_consumer' => $defaultConsumer,
             'enqueue.transport.custom.queue_consumer' => $customConsumer,
-        ]));
+        ]), 'default');
 
         $tester = new CommandTester($command);
         $tester->execute(['--transport' => 'custom']);
@@ -114,7 +114,7 @@ public function testThrowIfNotDefinedTransportRequested()
 
         $command = new ConsumeCommand(new Container([
             'enqueue.transport.default.queue_consumer' => $defaultConsumer,
-        ]));
+        ]), 'default');
 
         $tester = new CommandTester($command);