Fix errors reported by static analysers.

Author: ADmad

.travis.yml

@@ -28,7 +28,11 @@ script:
   - if [[ $DEFAULT == 1 && $TRAVIS_PHP_VERSION != 7.3 ]]; then vendor/bin/phpunit; fi
   - if [[ $DEFAULT == 1 && $TRAVIS_PHP_VERSION == 7.3 ]]; then vendor/bin/phpunit --coverage-clover=clover.xml; fi
 
-  - if [[ $STATIC_ANALYSIS == 1 ]]; then composer stan; fi
+  - |
+      if [[ $STATIC_ANALYSIS == 1 ]]; then
+        phpstan analyse src/
+        psalm.phar
+      fi
   - if [[ $PHPCS == 1 ]]; then composer cs-check; fi
 
 after_success:

src/Command/WorkerCommand.php

@@ -85,13 +85,6 @@ protected function getQueueExtension(Arguments $args, LoggerInterface $logger):
     {
         $maxIterations = (int)$args->getOption('max-iterations');
         $maxRuntime = (int)$args->getOption('max-runtime');
-        if ($maxIterations === null) {
-            $maxIterations = 0;
-        }
-
-        if ($maxRuntime === null) {
-            $maxRuntime = 0;
-        }
 
         return new QueueExtension($maxIterations, $maxRuntime, $logger);
     }
@@ -104,12 +97,12 @@ protected function getQueueExtension(Arguments $args, LoggerInterface $logger):
      */
     protected function getLogger(Arguments $args): LoggerInterface
     {
-        $logger = new NullLogger();
+        $logger = null;
         if (!empty($args->getOption('verbose'))) {
-            $logger = Log::engine($args->getOption('logger'));
+            $logger = Log::engine((string)$args->getOption('logger'));
         }
 
-        return $logger;
+        return $logger ?? new NullLogger();
     }
 
     /**
@@ -123,7 +116,7 @@ public function execute(Arguments $args, ConsoleIo $io)
         $processor = new Processor($logger);
         $extension = $this->getQueueExtension($args, $logger);
 
-        $config = $args->getOption('config');
+        $config = (string)$args->getOption('config');
         if (!Configure::check(sprintf('Queue.%s', $config))) {
             $io->error(sprintf('Configuration key "%s" was not found', $config));
             $this->abort();
@@ -137,13 +130,14 @@ public function execute(Arguments $args, ConsoleIo $io)
                 $this->abort();
             }
 
+            /** @var \Cake\Event\EventListenerInterface $listener */
             $listener = new $listenerClassName();
             $processor->getEventManager()->on($listener);
             $extension->getEventManager()->on($listener);
         }
         $url = Configure::read(sprintf('Queue.%s.url', $config));
         $client = new SimpleClient($url, $logger);
-        $client->bindTopic($args->getOption('queue'), $processor);
+        $client->bindTopic((string)$args->getOption('queue'), $processor);
         $client->consume($extension);
     }
 }