src/phinde/Queue.php


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

<?php
namespace phinde;

class Queue
{
    protected $gmclient;

    public function __construct()
    {
        $this->gmclient = new \GearmanClient();
        $this->gmclient->addServer('127.0.0.1');
    }

    public function addToProcessList($linkUrl, $actions)
    {
        Log::info(
            "Queuing for processing: $linkUrl"
            . ' (' . implode(',', $actions) . ')'
        );

        $this->gmclient->doBackground(
            $GLOBALS['phinde']['queuePrefix'] . 'phinde_process',
            serialize(
                array(
                    'url'     => $linkUrl,
                    'actions' => $actions,
                )
            )
        );
        if ($this->gmclient->returnCode() != GEARMAN_SUCCESS) {
            Log::error(
                'Error queueing URL processing for '
                . $linkUrl . "\n"
                . 'Error code: ' . $this->gmclient->returnCode()
            );
            exit(2);
        }
    }
}
?>