RedisQ\RedisQ

Complexity

Total Complexity

5

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	1

Importance

Changes	3
Bugs	1	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
B	queueObject()	0	24	2
A	registerListener()	0	5	1
A	listen()	0	18	2

<?php

namespace RedisQ;

class RedisQ
{
    public function queueObject($object)
    {
        global $redis;

Use of global functionality is not recommended; it makes your code harder to test, and less reusable.

        $wrapped = serialize($object);

        $allQueues = new RedisTtlSortedSet('redisQ:allQueues');
	$objectQueues = new RedisTtlSortedSet('objectQueues');
        $queues = $allQueues->getMembers();

        $multi = $redis->multi();

        // Store an instance of the object
        $objectID = 'redisQ:objectID:'.uniqID().md5($wrapped);
	$objectQueues->add(time(), $objectID);
        $multi->setex($objectID, 9600, $wrapped);

        // Add objectID to all queues
        foreach ($queues as $queueID) {
            $multi->lPush($queueID, $objectID);
            $multi->expire($queueID, 9600);
        }
        $multi->exec();
    }

    public function registerListener($queueID)
    {
        $allQueues = new RedisTtlSortedSet('redisQ:allQueues');
        $allQueues->add(time(), $queueID);
    }

    public function listen($queueID)
    {
        global $redis;

Use of global functionality is not recommended; it makes your code harder to test, and less reusable.

        $rQueueID = "redisQ:queueID:$queueID";

        self::registerListener($rQueueID);

        $pop = $redis->blPop($rQueueID, 10);
        if (!isset($pop[1])) {
            return;
        }

        $objectID = $pop[1];
        $object = $redis->get($objectID);

        return unserialize($object);
    }
}