Fixed unit test

This commit is contained in:
Ruud Kamphuis 2013-03-13 13:03:19 +01:00
parent 86ae77811d
commit f379d3a36d
2 changed files with 1 additions and 2 deletions

View File

@ -164,7 +164,6 @@ class Resque_Worker
$this->log('Starting blocking with timeout of ' . $interval, self::LOG_VERBOSE); $this->log('Starting blocking with timeout of ' . $interval, self::LOG_VERBOSE);
$this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with blocking timeout ' . $interval); $this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with blocking timeout ' . $interval);
} else { } else {
$this->log('Starting with interval of ' . $interval, self::LOG_VERBOSE);
$this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with interval ' . $interval); $this->updateProcLine('Waiting for ' . implode(',', $this->queues) . ' with interval ' . $interval);
} }

View File

@ -257,7 +257,7 @@ class Resque_Tests_WorkerTest extends Resque_Tests_TestCase
Resque::enqueue('jobs', 'Test_Job_2'); Resque::enqueue('jobs', 'Test_Job_2');
$i = 1; $i = 1;
while($job = $worker->reserve(60)) while($job = $worker->reserve(true, 1))
{ {
$this->assertEquals('Test_Job_' . $i, $job->payload['class']); $this->assertEquals('Test_Job_' . $i, $job->payload['class']);