Skip to content

Commit 981ef3d

Browse files
committed
worker process name always includes all queues name
this facilitates monitoring of each worker process
1 parent 968b7e6 commit 981ef3d

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

lib/Resque/Worker.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -157,9 +157,9 @@ public function work($interval = Resque::DEFAULT_INTERVAL, $blocking = false)
157157
if(!$this->paused) {
158158
if($blocking === true) {
159159
$this->logger->log(Psr\Log\LogLevel::INFO, 'Starting blocking with timeout of {interval}', array('interval' => $interval));
160-
$this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with blocking timeout ' . $interval);
160+
$this->updateProcLine('Waiting with blocking timeout ' . $interval);
161161
} else {
162-
$this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with interval ' . $interval);
162+
$this->updateProcLine('Waiting with interval ' . $interval);
163163
}
164164

165165
$job = $this->reserve($blocking, $interval);
@@ -179,7 +179,7 @@ public function work($interval = Resque::DEFAULT_INTERVAL, $blocking = false)
179179
$this->updateProcLine('Paused');
180180
}
181181
else {
182-
$this->updateProcLine('Waiting for ' . implode(',', $this->queues));
182+
$this->updateProcLine('Waiting');
183183
}
184184

185185
usleep($interval * 1000000);
@@ -323,7 +323,7 @@ private function startup()
323323
*/
324324
private function updateProcLine($status)
325325
{
326-
$processTitle = 'resque-' . Resque::VERSION . ': ' . $status;
326+
$processTitle = 'resque-' . Resque::VERSION . ' (' . implode(',', $this->queues) . '): ' . $status;
327327
if(function_exists('cli_set_process_title') && PHP_OS !== 'Darwin') {
328328
cli_set_process_title($processTitle);
329329
}

0 commit comments

Comments
 (0)