diff --git a/lib/Resque/Worker.php b/lib/Resque/Worker.php index 04714c1c..e5574301 100644 --- a/lib/Resque/Worker.php +++ b/lib/Resque/Worker.php @@ -157,9 +157,9 @@ public function work($interval = Resque::DEFAULT_INTERVAL, $blocking = false) if(!$this->paused) { if($blocking === true) { $this->logger->log(Psr\Log\LogLevel::INFO, 'Starting blocking with timeout of {interval}', array('interval' => $interval)); - $this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with blocking timeout ' . $interval); + $this->updateProcLine('Waiting with blocking timeout ' . $interval); } else { - $this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with interval ' . $interval); + $this->updateProcLine('Waiting with interval ' . $interval); } $job = $this->reserve($blocking, $interval); @@ -179,7 +179,7 @@ public function work($interval = Resque::DEFAULT_INTERVAL, $blocking = false) $this->updateProcLine('Paused'); } else { - $this->updateProcLine('Waiting for ' . implode(',', $this->queues)); + $this->updateProcLine('Waiting'); } usleep($interval * 1000000); @@ -323,7 +323,7 @@ private function startup() */ private function updateProcLine($status) { - $processTitle = 'resque-' . Resque::VERSION . ': ' . $status; + $processTitle = 'resque-' . Resque::VERSION . ' (' . implode(',', $this->queues) . '): ' . $status; if(function_exists('cli_set_process_title') && PHP_OS !== 'Darwin') { cli_set_process_title($processTitle); }