Add support for custom connection name and update tests to test this scenario

Author: marickvantuil

src/TaskHandler.php

@@ -29,7 +29,7 @@ public function handle($task = null)
         $task = $task ?: $this->captureTask();
 
         $command = unserialize($task['data']['command']);
-        $connection = $command->connection ?? 'cloudtasks';
+        $connection = $command->connection ?? config('queue.default');
 
         $this->authorizeRequest($connection);
 

tests/TaskHandlerTest.php

@@ -165,7 +165,7 @@ public function after_max_attempts_it_will_log_to_failed_table()
         }
 
         $this->assertDatabaseHas('failed_jobs', [
-            'connection' => 'cloudtasks',
+            'connection' => 'my-cloudtasks-connection',
             'queue' => 'my-queue',
             'payload' => rtrim($this->failingJobPayload()),
         ]);

tests/TestCase.php

@@ -59,8 +59,8 @@ protected function getEnvironmentSetUp($app)
         }
 
         $app['config']->set('cache.default', 'file');
-        $app['config']->set('queue.default', 'cloudtasks');
-        $app['config']->set('queue.connections.cloudtasks', [
+        $app['config']->set('queue.default', 'my-cloudtasks-connection');
+        $app['config']->set('queue.connections.my-cloudtasks-connection', [
             'driver' => 'cloudtasks',
             'queue' => 'test-queue',
             'project' => 'test-project',
@@ -72,6 +72,6 @@ protected function getEnvironmentSetUp($app)
 
     protected function setConfigValue($key, $value)
     {
-        $this->app['config']->set('queue.connections.cloudtasks.' . $key, $value);
+        $this->app['config']->set('queue.connections.my-cloudtasks-connection.' . $key, $value);
     }
 }