Add connectionName

Author: barryvdh

src/AsyncQueue.php

@@ -12,6 +12,9 @@ class AsyncQueue extends DatabaseQueue
 
     /** @var string */
     protected $binaryArgs;
+    
+    /** @var string */
+    protected $connectionName;
 
     /**
      * @param  \Illuminate\Database\Connection  $database
@@ -21,11 +24,12 @@ class AsyncQueue extends DatabaseQueue
      * @param  string  $binary
      * @param  string|array  $binaryArgs
      */
-    public function __construct(Connection $database, $table, $default = 'default', $expire = 60, $binary = 'php', $binaryArgs = '')
+    public function __construct(Connection $database, $table, $default = 'default', $expire = 60, $binary = 'php', $binaryArgs = '', $connectionName = '')
     {
         parent::__construct($database, $table, $default, $expire);
         $this->binary = $binary;
         $this->binaryArgs = $binaryArgs;
+        $this->connectionName = $connectionName;
     }
 
     /**
@@ -144,14 +148,14 @@ public function startProcess($queue, $id)
      */
     protected function getCommand($queue, $id)
     {
-        $connection = null;
-        $cmd = '%s artisan queue:async %d %d --env=%s --queue=%s';
+        $connection = $this->connectionName;
+        $cmd = '%s artisan queue:async %d %s --env=%s --queue=%s';
         $cmd = $this->getBackgroundCommand($cmd);
 
         $binary = $this->getPhpBinary();
         $environment = $this->container->environment();
 
-        return sprintf($cmd, $binary, $id, $connection, $environment, $queue);
+        return sprintf($cmd, $binary, $id, $connection, $environment, $this->getQueue($queue));
     }
 
     /**

src/Connectors/AsyncConnector.php

@@ -17,13 +17,15 @@ class AsyncConnector extends DatabaseConnector
      */
     public function connect(array $config)
     {
+        var_dump($config);
         return new AsyncQueue(
 			$this->connections->connection(array_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, 'binary_args', ''),
+            array_get($config, 'connection_name', '')
 		);
     }
 }