setup: check json before dropping current index

[phinde.git] / bin / phinde-worker.php

diff --git a/bin/phinde-worker.php b/bin/phinde-worker.php
index 7adb7af95aa584a188b010165ec453725f7149df..939db1f9a37691dbbd016072ce1608e23415860c 100755 (executable)
--- a/bin/phinde-worker.php
+++ b/bin/phinde-worker.php
@@ -32,7 +32,7 @@ $gmworker->addServer('127.0.0.1');
 
 if (isset($queues['crawl'])) {
     $gmworker->addFunction(
 
 if (isset($queues['crawl'])) {
     $gmworker->addFunction(

-        'phinde_crawl',
+        $GLOBALS['phinde']['queuePrefix'] . 'phinde_crawl',

         function(\GearmanJob $job) {
             $data = unserialize($job->workload());
             echo "-- Crawling " . $data['url'] . "\n";
         function(\GearmanJob $job) {
             $data = unserialize($job->workload());
             echo "-- Crawling " . $data['url'] . "\n";


@@ -42,7 +42,7 @@ if (isset($queues['crawl'])) {
 }
 if (isset($queues['index'])) {
     $gmworker->addFunction(
 }
 if (isset($queues['index'])) {
     $gmworker->addFunction(

-        'phinde_index',
+        $GLOBALS['phinde']['queuePrefix'] . 'phinde_index',

         function(\GearmanJob $job) {
             $data = unserialize($job->workload());
             echo "-- Indexing " . $data['url'] . "\n";
         function(\GearmanJob $job) {
             $data = unserialize($job->workload());
             echo "-- Indexing " . $data['url'] . "\n";