resquebundle / resque

     * @param $timestamp

     * @return array

     */

    public function getJobsForTimestamp($timestamp)

    {

        $jobs = \Resque::redis()->lrange('delayed:' . $timestamp, 0, -1);

        $out = [];

        foreach ($jobs as $job) {

            $out[] = json_decode($job, TRUE);

        }

        return $out;

    }

    /**

     * @param $queue

     * @param int $count

     * @return array

     */

    public function getFailedJobs($start = -100, $count = 100)

    {

        $jobs = \Resque::redis()->lrange('failed', $start, $count);

        $result = [];

        foreach ($jobs as $job) {

            $result[] = new FailedJob(json_decode($job, TRUE));

        }

        return $result;

    }

}