Laravel 5.7 queues compatibility

Author: joesb

src/Queue/KafkaQueue.php

@@ -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, []);
     }
 
     /**
@@ -98,6 +98,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
     {
         try {
             $topic = $this->getTopic($queue);
+            \Illuminate\Support\Facades\Log::debug('queue: ' . $queue);
 
             $pushRawCorrelationId = $this->getCorrelationId();
 
@@ -222,14 +223,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,
         ]);