@@ -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 |