idanoo/php-resque
1
0
Fork 0
mirror of https://github.com/idanoo/php-resque synced 2025-07-01 05:32:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Trying to pass builds..

Browse source
This commit is contained in:
Daniel Mason 2018-05-25 20:24:00 +12:00
parent 44413588f4
commit 1085ac2412
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
lib/Resque/Job.php
View file

@ -93,7 +93,7 @@ class Resque_Job
*/ */
public static function reserve($queue) public static function reserve($queue)
{ {
$payload = Resque::pop($queue); $payload = Resque::pop($queue);
if(!is_array($payload)) { if(!is_array($payload)) {
return false; return false;
} }
@ -112,7 +112,6 @@ class Resque_Job
public static function reserveBlocking(array $queues, $timeout = null) public static function reserveBlocking(array $queues, $timeout = null)
{ {
$item = Resque::blpop($queues, $timeout); $item = Resque::blpop($queues, $timeout);
if(!is_array($item)) { if(!is_array($item)) {
return false; return false;
} }

1
test/Resque/Tests/JobStatusTest.php
View file

@ -36,6 +36,7 @@ class Resque_Tests_JobStatusTest extends Resque_Tests_TestCase
$token = Resque::enqueue('jobs', 'Test_Job', null, true); $token = Resque::enqueue('jobs', 'Test_Job', null, true);
$job = Resque_Job::reserve('jobs'); $job = Resque_Job::reserve('jobs');
$this->assertEquals(Resque_Job_Status::STATUS_WAITING, $job->getStatus()); $this->assertEquals(Resque_Job_Status::STATUS_WAITING, $job->getStatus());
} }
public function testQueuedJobReturnsQueuedStatus() public function testQueuedJobReturnsQueuedStatus()