@@ -8,7 +8,9 @@ |
||
8 | 8 | } |
9 | 9 | |
10 | 10 | $package = unserialize(RedisQ\RedisQ::listen($queueID)); |
11 | -if ($package === false) $package = null; |
|
11 | +if ($package === false) { |
|
12 | + $package = null; |
|
13 | +} |
|
12 | 14 | |
13 | 15 | $response = ['package' => $package]; |
14 | 16 | header('Content-Type: application/json'); |
@@ -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 |