Skip to content

Commit

Permalink
Merge pull request #14 from joesb/dev-master
Browse files Browse the repository at this point in the history
Payloads: Laravel 5.7 queues compatibility?
  • Loading branch information
petermein authored Mar 21, 2019
2 parents ff70bcb + 1d6c5c6 commit 03baedf
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/Queue/KafkaQueue.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->pushRaw($this->createPayload($job, $data), $queue, []);
return $this->pushRaw($this->createPayload($job, $queue, $data), $queue, []);
}

/**
Expand Down Expand Up @@ -222,14 +222,14 @@ public function getConfig()
* Create a payload array from the given job and data.
*
* @param string $job
* @param mixed $data
* @param string $queue
* @param mixed $data
*
* @return array
*/
protected function createPayloadArray($job, $data = '', $queue = null)
protected function createPayloadArray($job, $queue = null, $data = '')
{
return array_merge(parent::createPayloadArray($job, $data), [
return array_merge(parent::createPayloadArray($job, $queue, $data), [
'id' => $this->getCorrelationId(),
'attempts' => 0,
]);
Expand Down

0 comments on commit 03baedf

Please sign in to comment.