aboutsummaryrefslogtreecommitdiff
path: root/bin/phinde-worker.php
diff options
context:
space:
mode:
authorChristian Weiske <cweiske@cweiske.de>2016-11-10 20:52:35 +0100
committerChristian Weiske <cweiske@cweiske.de>2016-11-10 20:52:35 +0100
commit696fcd7ce4d495e356667019493bf312e2a6e47b (patch)
tree3e8d60dad08dbe31660f2532d8ce893d35d50130 /bin/phinde-worker.php
parent9ff01ebe8cde0a07ad2a480d1a45eb1a29cb113d (diff)
downloadphinde-696fcd7ce4d495e356667019493bf312e2a6e47b.tar.gz
phinde-696fcd7ce4d495e356667019493bf312e2a6e47b.zip
add log class
Diffstat (limited to 'bin/phinde-worker.php')
-rwxr-xr-xbin/phinde-worker.php9
1 files changed, 5 insertions, 4 deletions
diff --git a/bin/phinde-worker.php b/bin/phinde-worker.php
index 9f8c35a..9b65e32 100755
--- a/bin/phinde-worker.php
+++ b/bin/phinde-worker.php
@@ -13,9 +13,10 @@ $gmworker->addFunction(
$GLOBALS['phinde']['queuePrefix'] . 'phinde_process',
function(\GearmanJob $job) {
$data = unserialize($job->workload());
- echo "-- Processing " . $data['url']
+ Log::info(
+ "-- Processing " . $data['url']
. ' (' . implode(',', $data['actions']) . ')'
- . "\n";
+ );
passthru(
'./process.php ' . escapeshellarg($data['url'])
. ' ' . implode(' ', $data['actions'])
@@ -26,7 +27,7 @@ $gmworker->addFunction(
$gmworker->addFunction(
$GLOBALS['phinde']['queuePrefix'] . 'phinde_quit',
function(\GearmanJob $job) {
- echo "Got exit job\n";
+ Log::info('Got exit job');
$job->sendComplete('');
exit(0);
}
@@ -34,7 +35,7 @@ $gmworker->addFunction(
while ($gmworker->work()) {
if ($gmworker->returnCode() != GEARMAN_SUCCESS) {
- echo 'Error running job: ' . $gmworker->returnCode() . "\n";
+ Log::error('Error running job: ' . $gmworker->returnCode());
break;
}
}