Laravel 5.8 support

composer.json

@@ -11,8 +11,8 @@
     ],
     "require": {
         "php": ">=7",
-        "illuminate/support": "5.5.x|5.6.x|5.7.x",
-        "illuminate/console": "5.5.x|5.6.x|5.7.x",
+        "illuminate/support": "5.5.x|5.6.x|5.7.x|5.8.x",
+        "illuminate/console": "5.5.x|5.6.x|5.7.x|5.8.x",
         "symfony/process": "^3.2|^4"
     },
     "autoload": {

readme.md

@@ -1,4 +1,4 @@
-# Laravel 5.5 Async Queue Driver
+# Laravel 5 Async Queue Driver
 
 ## Push a function/closure to the background.
 

src/AsyncQueue.php

@@ -59,7 +59,7 @@ public function push($job, $data = '', $queue = null)
      * @param  array   $options
      * @return mixed
      */
-    public function pushRaw($payload, $queue = null, array $options = array())
+    public function pushRaw($payload, $queue = null, array $options = [])
     {
         $id = parent::pushRaw($payload, $queue, $options);
         $this->startProcess($id);
@@ -164,23 +164,24 @@ protected function getCommand($id)
     protected function getPhpBinary()
     {
         $path = $this->binary;
-        if (!defined('PHP_WINDOWS_VERSION_BUILD')) {
+        if ( ! defined('PHP_WINDOWS_VERSION_BUILD')) {
             $path = escapeshellarg($path);
         }
 
         $args = $this->binaryArgs;
-        if(is_array($args)){
+        if (is_array($args)) {
             $args = implode(' ', $args);
         }
-        return trim($path.' '.$args);
+
+        return trim($path . ' ' . $args);
     }
 
     protected function getBackgroundCommand($cmd)
     {
         if (defined('PHP_WINDOWS_VERSION_BUILD')) {
-            return 'start /B '.$cmd.' > NUL';
-        } else {
-            return $cmd.' > /dev/null 2>&1 &';
+            return 'start /B ' . $cmd . ' > NUL';
         }
+
+        return $cmd . ' > /dev/null 2>&1 &';
     }
 }

src/AsyncServiceProvider.php

@@ -71,6 +71,6 @@ protected function registerAsyncConnector($manager)
      */
     public function provides()
     {
-        return array('command.queue.async');
+        return ['command.queue.async'];
     }
 }

src/Connectors/AsyncConnector.php

@@ -4,6 +4,7 @@
 
 use Barryvdh\Queue\AsyncQueue;
 use Illuminate\Queue\Connectors\DatabaseConnector;
+use Illuminate\Support\Arr;
 
 class AsyncConnector extends DatabaseConnector
 {
@@ -18,13 +19,13 @@ class AsyncConnector extends DatabaseConnector
     public function connect(array $config)
     {
         return new AsyncQueue(
-			$this->connections->connection(array_get($config, 'connection')),
+			$this->connections->connection(Arr::get($config, 'connection')),
 			$config['table'],
 			$config['queue'],
-			array_get($config, 'expire', 60),
-            array_get($config, 'binary', 'php'),
-            array_get($config, 'binary_args', ''),
-            array_get($config, 'connection_name', '')
+			Arr::get($config, 'expire', 60),
+            Arr::get($config, 'binary', 'php'),
+            Arr::get($config, 'binary_args', ''),
+            Arr::get($config, 'connection_name', '')
 		);
     }
 }

src/Console/AsyncCommand.php

@@ -4,11 +4,9 @@
 
 use Barryvdh\Queue\AsyncQueue;
 use Illuminate\Console\Command;
-use Illuminate\Queue\DatabaseQueue;
 use Illuminate\Queue\Worker;
 use Illuminate\Queue\WorkerOptions;
 use Symfony\Component\Console\Input\InputArgument;
-use Symfony\Component\Console\Input\InputOption;
 
 class AsyncCommand extends Command
 {
@@ -63,9 +61,12 @@ public function handle(WorkerOptions $options)
 
     /**
      *  Process the job
+     *
      * @param string $connectionName
      * @param integer $id
      * @param WorkerOptions $options
+     *
+     * @throws \Throwable
      */
     protected function processJob($connectionName, $id, $options)
     {
@@ -90,9 +91,9 @@ protected function processJob($connectionName, $id, $options)
      */
     protected function getArguments()
     {
-        return array(
-            array('id', InputArgument::REQUIRED, 'The Job ID'),
-            array('connection', InputArgument::OPTIONAL, 'The name of connection'),
-        );
+        return [
+            ['id', InputArgument::REQUIRED, 'The Job ID'],
+            ['connection', InputArgument::OPTIONAL, 'The name of connection'],
+        ];
     }
 }