enqueuer channels

Author: asika32764

src/Core/Queue/Command/QueueWorkerCommand.php

@@ -161,7 +161,7 @@ public function configure(Command $command): void
         $command->addOption(
             'enqueuer',
             'e',
-            InputOption::VALUE_NONE,
+            InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY,
             'Also run the enqueuer service in the worker.',
         );
 
@@ -211,7 +211,11 @@ public function execute(IOInterface $io): int
         );
 
         // Enqueuer
-        if ($io->getOption('enqueuer')) {
+        $enqueuerChannels = $io->getOption('enqueuer');
+
+        if (count($enqueuerChannels) > 0) {
+            $enqueuerChannels = array_filter($enqueuerChannels) ?: null;
+
             $io->style()->warning(
                 [
                     'Running Enqueuer with queue worker.',
@@ -227,6 +231,7 @@ public function execute(IOInterface $io): int
             $this->prepareDebugServices($io, $enqueuer);
 
             $worker->enqueuer = $enqueuer;
+            $worker->enqueuerChannels = $enqueuerChannels;
 
             $this->runEnqueuerConfigScripts(
                 'init_scripts',