@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | { |
74 | 74 | $item = null; |
75 | 75 | while ($item = ResqueScheduler::nextItemForTimestamp($timestamp)) { |
76 | - $this->log('queueing ' . $item['class'] . ' in ' . $item['queue'] .' [delayed]'); |
|
76 | + $this->log('queueing ' . $item['class'] . ' in ' . $item['queue'] . ' [delayed]'); |
|
77 | 77 | |
78 | 78 | Resque_Event::trigger('beforeDelayedEnqueue', array( |
79 | 79 | 'queue' => $item['queue'], |
@@ -105,7 +105,7 @@ discard block |
||
105 | 105 | */ |
106 | 106 | private function updateProcLine($status) |
107 | 107 | { |
108 | - if(function_exists('setproctitle')) { |
|
108 | + if (function_exists('setproctitle')) { |
|
109 | 109 | setproctitle('resque-scheduler-' . ResqueScheduler::VERSION . ': ' . $status); |
110 | 110 | } |
111 | 111 | } |
@@ -117,10 +117,10 @@ discard block |
||
117 | 117 | */ |
118 | 118 | public function log($message) |
119 | 119 | { |
120 | - if($this->logLevel == self::LOG_NORMAL) { |
|
120 | + if ($this->logLevel == self::LOG_NORMAL) { |
|
121 | 121 | fwrite(STDOUT, "*** " . $message . "\n"); |
122 | 122 | } |
123 | - else if($this->logLevel == self::LOG_VERBOSE) { |
|
123 | + else if ($this->logLevel == self::LOG_VERBOSE) { |
|
124 | 124 | fwrite(STDOUT, "** [" . strftime('%T %Y-%m-%d') . "] " . $message . "\n"); |
125 | 125 | } |
126 | 126 | } |