@@ 315-324 (lines=10) @@ | ||
312 | * @param $timestamp |
|
313 | * @return array |
|
314 | */ |
|
315 | public function getJobsForTimestamp($timestamp) |
|
316 | { |
|
317 | $jobs = \Resque::redis()->lrange('delayed:' . $timestamp, 0, -1); |
|
318 | $out = []; |
|
319 | foreach ($jobs as $job) { |
|
320 | $out[] = json_decode($job, TRUE); |
|
321 | } |
|
322 | ||
323 | return $out; |
|
324 | } |
|
325 | ||
326 | /** |
|
327 | * @param $queue |
|
@@ 343-354 (lines=12) @@ | ||
340 | * @param int $count |
|
341 | * @return array |
|
342 | */ |
|
343 | public function getFailedJobs($start = -100, $count = 100) |
|
344 | { |
|
345 | $jobs = \Resque::redis()->lrange('failed', $start, $count); |
|
346 | ||
347 | $result = []; |
|
348 | ||
349 | foreach ($jobs as $job) { |
|
350 | $result[] = new FailedJob(json_decode($job, TRUE)); |
|
351 | } |
|
352 | ||
353 | return $result; |
|
354 | } |
|
355 | } |
|
356 |