Merge pull request #17 from GrahamCampbell/env

More robust environment support

Author: barryvdh

composer.json

@@ -11,6 +11,7 @@
         "php": ">=5.3.0",
         "illuminate/support": "~4.0",
         "illuminate/console": "~4.0",
+        "sebastian/environment": "~1.0",
         "symfony/process": "~2.3"
     },
     "autoload": {

src/AsyncQueue.php

@@ -5,6 +5,7 @@
 use Barryvdh\Queue\Models\Job;
 use Illuminate\Queue\Queue;
 use Illuminate\Queue\QueueInterface;
+use SebastianBergmann\Environment\Runtime;
 use Symfony\Component\Process\Process;
 
 class AsyncQueue extends Queue implements QueueInterface
@@ -59,18 +60,45 @@ public function storeJob($job, $data, $delay = 0)
      */
     public function startProcess($jobId)
     {
-        $environment = $this->container->environment();
+        $command = $this->getCommand();
         $cwd = $this->container['path.base'];
-        $string = 'php artisan queue:async %d --env=%s ';
+
+        $process = new Process($command, $cwd);
+        $process->run();
+    }
+
+    /**
+     * Get the Artisan command as a string for the job id.
+     *
+     * @param int $jobId
+     *
+     * @return string
+     */
+    protected function getCommand($jobId)
+    {
+        $string = $this->getBinary().' artisan queue:async %d --env=%s ';
+
         if (defined('PHP_WINDOWS_VERSION_BUILD')) {
             $string = 'start /B '.$string.' > NUL';
         } else {
             $string = 'nohup '.$string.' > /dev/null 2>&1 &';
         }
 
-        $command = sprintf($string, $jobId, $environment);
-        $process = new Process($command, $cwd);
-        $process->run();
+        $environment = $this->container->environment();
+
+        return sprintf($string, $jobId, $environment);
+    }
+
+    /**
+     * Get the php binary path.
+     *
+     * @return string
+     */
+    protected function getBinary()
+    {
+        $runtime = new Runtime();
+
+        return $runtime->getBinary();
     }
 
     /**