Add ability to specify queue connection and name

Author: stevebauman

config/metrics.php

@@ -14,5 +14,8 @@
     |
     */
 
-    'queue' => env('METRICS_QUEUE', false),
+    'queue' => env('METRICS_QUEUE', false) ? [
+        'connection' => env('QUEUE_CONNECTION', 'sync'),
+        'queue' => null,
+    ] : false,
 ];

src/DatabaseMetricManager.php

@@ -45,9 +45,11 @@ public function commit(): void
         }
 
         if ($queue = config('metrics.queue')) {
-            CommitMetrics::dispatch($metrics, $queue);
+            CommitMetrics::dispatch($metrics)
+                ->onQueue($queue['queue'] ?? null)
+                ->onConnection($queue['connection'] ?? null);
         } else {
-            (new CommitMetrics($metrics, $queue))->handle();
+            (new CommitMetrics($metrics))->handle();
         }
 
         $this->repository->flush();

src/Jobs/CommitMetrics.php

@@ -6,18 +6,18 @@
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Support\Collection;
 
 class CommitMetrics implements ShouldQueue
 {
-    use Dispatchable, Queueable;
+    use Dispatchable, InteractsWithQueue, Queueable;
 
     /**
      * Constructor.
      */
     public function __construct(
         public array $metrics,
-        public bool $shouldQueue,
     ) {}
 
     /**
@@ -38,8 +38,10 @@ public function handle(): void
                 ]));
             })
             ->each(function (Collection $metrics) {
-                if ($this->shouldQueue) {
-                    RecordMetric::dispatch($metrics);
+                if (isset($this->job)) {
+                    RecordMetric::dispatch($metrics)
+                        ->onQueue($this->queue)
+                        ->onConnection($this->connection);
                 } else {
                     (new RecordMetric($metrics))->handle();
                 }