Skip to content

Commit a9f8112

Browse files
committed
Apply fixes from StyleCI
1 parent f4d9b2e commit a9f8112

File tree

5 files changed

+24
-9
lines changed

5 files changed

+24
-9
lines changed

src/queue/Worker.php

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,8 @@ public function daemon($connection, $queue, $delay = 0, $sleep = 3, $maxTries =
8080
while (true) {
8181

8282
$job = $this->getNextJob(
83-
$this->queue->connection($connection), $queue
83+
$this->queue->connection($connection),
84+
$queue
8485
);
8586

8687
if ($this->supportsAsyncSignals()) {
@@ -305,7 +306,9 @@ public function process($connection, $job, $maxTries = 0, $delay = 0)
305306
$this->event->trigger(new JobProcessing($connection, $job));
306307

307308
$this->markJobAsFailedIfAlreadyExceedsMaxAttempts(
308-
$connection, $job, (int) $maxTries
309+
$connection,
310+
$job,
311+
(int) $maxTries
309312
);
310313

311314
$job->fire();
@@ -392,7 +395,9 @@ protected function failJob($connection, $job, $e)
392395
$job->failed($e);
393396
} finally {
394397
$this->event->trigger(new JobFailed(
395-
$connection, $job, $e ?: new RuntimeException('ManuallyFailed')
398+
$connection,
399+
$job,
400+
$e ?: new RuntimeException('ManuallyFailed')
396401
));
397402
}
398403
}

src/queue/command/Retry.php

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,8 @@ public function handle()
4242
protected function retryJob($job)
4343
{
4444
$this->app['queue']->connection($job['connection'])->pushRaw(
45-
$this->resetAttempts($job['payload']), $job['queue']
45+
$this->resetAttempts($job['payload']),
46+
$job['queue']
4647
);
4748
}
4849

src/queue/command/Work.php

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,8 @@ protected function writeStatus(Job $job, $status, $type)
132132
"<{$type}>[%s][%s] %s</{$type}> %s",
133133
date('Y-m-d H:i:s'),
134134
$job->getJobId(),
135-
str_pad("{$status}:", 11), $job->getName()
135+
str_pad("{$status}:", 11),
136+
$job->getName()
136137
));
137138
}
138139

@@ -143,8 +144,10 @@ protected function writeStatus(Job $job, $status, $type)
143144
protected function logFailedJob(JobFailed $event)
144145
{
145146
$this->app['queue.failer']->log(
146-
$event->connection, $event->job->getQueue(),
147-
$event->job->getRawBody(), $event->exception
147+
$event->connection,
148+
$event->job->getQueue(),
149+
$event->job->getRawBody(),
150+
$event->exception
148151
);
149152
}
150153

src/queue/connector/Redis.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,9 @@ public function later($delay, $job, $data = '', $queue = null)
133133
protected function laterRaw($delay, $payload, $queue = null)
134134
{
135135
if ($this->redis->zadd(
136-
$this->getQueue($queue) . ':delayed', $this->availableAt($delay), $payload
136+
$this->getQueue($queue) . ':delayed',
137+
$this->availableAt($delay),
138+
$payload
137139
)) {
138140
return json_decode($payload, true)['id'] ?? null;
139141
}

src/queue/failed/Database.php

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,11 @@ public function log($connection, $queue, $payload, $exception)
4646
$exception = (string) $exception;
4747

4848
return $this->getTable()->insertGetId(compact(
49-
'connection', 'queue', 'payload', 'exception', 'fail_time'
49+
'connection',
50+
'queue',
51+
'payload',
52+
'exception',
53+
'fail_time'
5054
));
5155
}
5256

0 commit comments

Comments
 (0)