mmucklo /
DtcQueueBundle
@@ -432,7 +432,7 @@ |
||
| 432 | 432 | { |
| 433 | 433 | $cursor = null; |
| 434 | 434 | while ($jobs = $this->redis->zScan($cacheKey, $cursor, '', 100)) { |
| 435 | - $jobs = $this->redis->mget(array_map(function ($item) { |
|
| 435 | + $jobs = $this->redis->mget(array_map(function($item) { |
|
| 436 | 436 | return $this->getJobCacheKey($item); |
| 437 | 437 | }, array_keys($jobs))); |
| 438 | 438 | foreach ($jobs as $jobMessage) { |
