yiisoft#258: Fixed

Author: zhuravljov

src/cli/Command.php

@@ -142,7 +142,7 @@ public function beforeAction($action)
      */
     public function actionExec($id, $ttr, $attempt, $pid)
     {
-        if ($this->queue->execute($id, file_get_contents('php://stdin'), $ttr, $attempt, $pid)) {
+        if ($this->queue->execute($id, file_get_contents('php://stdin'), $ttr, $attempt, $pid ?: null)) {
             return self::EXEC_DONE;
         }
         return self::EXEC_RETRY;
@@ -169,7 +169,7 @@ protected function handleMessage($id, $message, $ttr, $attempt)
             $id,
             $ttr,
             $attempt,
-            $this->queue->getWorkerPid(),
+            $this->queue->getWorkerPid() ?: 0,
         ];
 
         foreach ($this->getPassedOptions() as $name) {

src/cli/Queue.php

@@ -57,7 +57,7 @@ abstract class Queue extends BaseQueue implements BootstrapInterface
     public $messageHandler;
 
     /**
-     * @var int current process ID of a worker.
+     * @var int|null current process ID of a worker.
      * @since 2.0.2
      */
     private $_workerPid;
@@ -127,7 +127,7 @@ protected function runWorker(callable $handler)
      * Gets process ID of a worker.
      *
      * @inheritdoc
-     * @return int
+     * @return int|null
      * @since 2.0.2
      */
     public function getWorkerPid()
@@ -152,7 +152,7 @@ protected function handleMessage($id, $message, $ttr, $attempt)
      * @param string $message
      * @param int $ttr time to reserve
      * @param int $attempt number
-     * @param int $workerPid of worker process
+     * @param int|null $workerPid of worker process
      * @return bool
      * @internal for worker command only
      */