Merge pull request #127 from CakeDC/issue/95

Add default processor if argument is not passed to avoid processor hash
cakephp · Jul 17, 2023 · 172ec7c · 172ec7c
2 parents 4e2729a + 54c0fc4
commit 172ec7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Command/WorkerCommand.php b/src/Command/WorkerCommand.php
@@ -204,7 +204,7 @@ public function execute(Arguments $args, ConsoleIo $io)
         $queue = $args->getOption('queue')
             ? (string)$args->getOption('queue')
             : Configure::read("Queue.{$config}.queue", 'default');
-        $processorName = $args->getOption('processor') ? (string)$args->getOption('processor') : null;
+        $processorName = $args->getOption('processor') ? (string)$args->getOption('processor') : 'default';
 
         $client->bindTopic($queue, $processor, $processorName);
         $client->consume($extension);