|
@@ -11,14 +11,14 @@ |
|
|
block discarded – undo |
|
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 |
Please login to merge, or discard this patch.