idanoo/php-resque
1
0
Fork 0
mirror of https://github.com/idanoo/php-resque.git synced 2024-11-22 08:15:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #90 from cballou/master

Browse Source 
Fixed Resque_Worker logging as it would always output verbose messaging.
This commit is contained in:
Chris Boulton 2013-02-28 04:57:04 -08:00
commit c18b5441f5
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lib/Resque/Worker.php
View File

@ -169,7 +169,7 @@ class Resque_Worker
break; break;
} }
// If no job was found, we sleep for $interval before continuing and checking again // If no job was found, we sleep for $interval before continuing and checking again
$this->log('Sleeping for ' . $interval, true); $this->log('Sleeping for ' . $interval, self::LOG_VERBOSE);
if($this->paused) { if($this->paused) {
$this->updateProcLine('Paused'); $this->updateProcLine('Paused');
} }
@ -518,16 +518,21 @@ class Resque_Worker
* Output a given log message to STDOUT. * Output a given log message to STDOUT.
* *
* @param string $message Message to output. * @param string $message Message to output.
* @param int $logLevel The logging level to capture
*/ */
public function log($message) public function log($message, $logLevel = self::LOG_NORMAL)
{ {
if($this->logLevel == self::LOG_NORMAL) { if ($logLevel > $this->logLevel) {
return;
}
if ($this->logLevel == self::LOG_NORMAL) {
fwrite(STDOUT, "*** " . $message . "\n"); fwrite(STDOUT, "*** " . $message . "\n");
return;
} }
else if($this->logLevel == self::LOG_VERBOSE) {
fwrite(STDOUT, "** [" . strftime('%T %Y-%m-%d') . "] " . $message . "\n"); fwrite(STDOUT, "** [" . strftime('%T %Y-%m-%d') . "] " . $message . "\n");
} }
}
/** /**
* Return an object describing the job this worker is currently working on. * Return an object describing the job this worker is currently working on.