@@ -11,14 +11,14 @@ |
||
11 | 11 | $wrapped = serialize($object); |
12 | 12 | |
13 | 13 | $allQueues = new RedisTtlSortedSet('redisQ:allQueues'); |
14 | - $objectQueues = new RedisTtlSortedSet('objectQueues'); |
|
14 | + $objectQueues = new RedisTtlSortedSet('objectQueues'); |
|
15 | 15 | $queues = $allQueues->getMembers(); |
16 | 16 | |
17 | 17 | $multi = $redis->multi(); |
18 | 18 | |
19 | 19 | // Store an instance of the object |
20 | 20 | $objectID = 'redisQ:objectID:'.uniqID().md5($wrapped); |
21 | - $objectQueues->add(time(), $objectID); |
|
21 | + $objectQueues->add(time(), $objectID); |
|
22 | 22 | $multi->setex($objectID, 9600, $wrapped); |
23 | 23 | |
24 | 24 | // Add objectID to all queues |
@@ -11,10 +11,14 @@ |
||
11 | 11 | } |
12 | 12 | |
13 | 13 | $ttw = (int) @$_GET['ttw']; |
14 | -if ($ttw == 0) $ttw = 10; |
|
14 | +if ($ttw == 0) { |
|
15 | + $ttw = 10; |
|
16 | +} |
|
15 | 17 | |
16 | 18 | $package = unserialize(RedisQ\RedisQ::listen($queueID, $ttw)); |
17 | -if ($package === false) $package = null; |
|
19 | +if ($package === false) { |
|
20 | + $package = null; |
|
21 | +} |
|
18 | 22 | |
19 | 23 | $response = ['package' => $package]; |
20 | 24 | header("Access-Control-Allow-Origin: *"); |