Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
taylorotwell committed Nov 30, 2020
1 parent a6b13a9 commit 010d4d7
Show file tree
Hide file tree
Showing 5 changed files with 9 additions and 9 deletions.
4 changes: 2 additions & 2 deletions src/Illuminate/Queue/BeanstalkdQueue.php
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ public function size($queue = null)
*/
public function push($job, $data = '', $queue = null)
{
return $this->enqueueUsing($job, function () use ($data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($job, $data, $queue) {
return $this->pushRaw($this->createPayload($job, $this->getQueue($queue), $data), $queue);
});
}
Expand Down Expand Up @@ -110,7 +110,7 @@ public function later($delay, $job, $data = '', $queue = null)
{
$pheanstalk = $this->pheanstalk->useTube($this->getQueue($queue));

return $this->enqueueUsing($job, function () use ($delay, $pheanstalk, $data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($delay, $pheanstalk, $job, $data, $queue) {
return $pheanstalk->put(
$this->createPayload($job, $this->getQueue($queue), $data),
Pheanstalk::DEFAULT_PRIORITY,
Expand Down
4 changes: 2 additions & 2 deletions src/Illuminate/Queue/DatabaseQueue.php
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ public function size($queue = null)
*/
public function push($job, $data = '', $queue = null)
{
return $this->enqueueUsing($job, function () use ($data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($job, $data, $queue) {
return $this->pushToDatabase($queue, $this->createPayload(
$job, $this->getQueue($queue), $data
));
Expand Down Expand Up @@ -111,7 +111,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
*/
public function later($delay, $job, $data = '', $queue = null)
{
return $this->enqueueUsing($job, function () use ($delay, $data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($delay, $job, $data, $queue) {
return $this->pushToDatabase($queue, $this->createPayload(
$job, $this->getQueue($queue), $data
), $delay);
Expand Down
2 changes: 1 addition & 1 deletion src/Illuminate/Queue/Queue.php
Original file line number Diff line number Diff line change
Expand Up @@ -265,7 +265,7 @@ protected function withCreatePayloadHooks($queue, array $payload)
*/
protected function enqueueUsing($job, $callback)
{
return call_user_func($callback);
return $callback();
}

/**
Expand Down
4 changes: 2 additions & 2 deletions src/Illuminate/Queue/RedisQueue.php
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ public function bulk($jobs, $data = '', $queue = null)
*/
public function push($job, $data = '', $queue = null)
{
return $this->enqueueUsing($job, function () use ($data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($job, $data, $queue) {
return $this->pushRaw($this->createPayload($job, $this->getQueue($queue), $data), $queue);
});
}
Expand Down Expand Up @@ -142,7 +142,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
*/
public function later($delay, $job, $data = '', $queue = null)
{
return $this->enqueueUsing($job, function () use ($delay, $data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($delay, $job, $data, $queue) {
return $this->laterRaw($delay, $this->createPayload($job, $this->getQueue($queue), $data), $queue);
});
}
Expand Down
4 changes: 2 additions & 2 deletions src/Illuminate/Queue/SqsQueue.php
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ public function size($queue = null)
*/
public function push($job, $data = '', $queue = null)
{
return $this->enqueueUsing($job, function () use ($data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($job, $data, $queue) {
return $this->pushRaw($this->createPayload($job, $queue ?: $this->default, $data), $queue);
});
}
Expand Down Expand Up @@ -114,7 +114,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
*/
public function later($delay, $job, $data = '', $queue = null)
{
return $this->enqueueUsing($job, function () use ($delay, $data, $queue, $job) {
return $this->enqueueUsing($job, function () use ($delay, $job, $data, $queue) {
return $this->sqs->sendMessage([
'QueueUrl' => $this->getQueue($queue),
'MessageBody' => $this->createPayload($job, $queue ?: $this->default, $data),
Expand Down

0 comments on commit 010d4d7

Please sign in to comment.