@@ -3,7 +3,6 @@ |
||
3 | 3 | |
4 | 4 | use Dtc\QueueBundle\Model\Job as BaseJob; |
5 | 5 | use Dtc\QueueBundle\Model\JobManagerInterface; |
6 | - |
|
7 | 6 | use PhpAmqpLib\Connection\AMQPConnection; |
8 | 7 | use PhpAmqpLib\Message\AMQPMessage; |
9 | 8 |
@@ -68,7 +68,7 @@ discard block |
||
68 | 68 | set_time_limit($processTimeout); // Set an hour timeout |
69 | 69 | |
70 | 70 | if ($jobId = $input->getOption('job_id')) { |
71 | - return $this->runJobById($jobId); // Run a single job |
|
71 | + return $this->runJobById($jobId); // Run a single job |
|
72 | 72 | } |
73 | 73 | |
74 | 74 | try { |
@@ -96,7 +96,7 @@ discard block |
||
96 | 96 | protected function reportJob(Job $job) |
97 | 97 | { |
98 | 98 | if ($job->getStatus() == Job::STATUS_ERROR) { |
99 | - $message = "Error with job id: {$job->getId()}\n" . $job->getMessage(); |
|
99 | + $message = "Error with job id: {$job->getId()}\n".$job->getMessage(); |
|
100 | 100 | $this->logger->error($message); |
101 | 101 | } |
102 | 102 |
@@ -115,8 +115,7 @@ |
||
115 | 115 | if ($priority) { |
116 | 116 | $this->assertEquals($priority, $job->getPriority(), |
117 | 117 | "Priority should be the same."); |
118 | - } |
|
119 | - else { |
|
118 | + } else { |
|
120 | 119 | $this->assertNull($job->getPriority(), "Priority should be null"); |
121 | 120 | } |
122 | 121 |