From 4c056a4db4e6a92342f18600024b80487a4ecfb1 Mon Sep 17 00:00:00 2001
From: Daniel Klabbers <daniel+git@klabbers.email>
Date: Thu, 4 Nov 2021 10:47:24 +0100
Subject: [PATCH] force queue

---
 src/Commands/BuildCommand.php | 3 ++-
 src/Provider.php              | 5 +++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/Commands/BuildCommand.php b/src/Commands/BuildCommand.php
index 1de8483..e558bf1 100644
--- a/src/Commands/BuildCommand.php
+++ b/src/Commands/BuildCommand.php
@@ -2,6 +2,7 @@
 
 namespace Blomstra\Search\Commands;
 
+use Blomstra\Search\Jobs\Job;
 use Blomstra\Search\Jobs\SavingJob;
 use Blomstra\Search\Seeders\Seeder;
 use Elasticsearch\Client;
@@ -80,7 +81,7 @@ class BuildCommand extends Command
                     $query->where('id', '<=', $id);
                 })
                 ->chunk(50, function (Collection $collection) use ($queue, &$total, $seeder) {
-                    $queue->push(new SavingJob($collection, $seeder));
+                    $queue->pushOn(Job::$onQueue, new SavingJob($collection, $seeder));
 
                     $this->info("Pushed into the index, type: {$seeder->type()}, amount: {$collection->count()}.");
 
diff --git a/src/Provider.php b/src/Provider.php
index dc93ac2..20de415 100644
--- a/src/Provider.php
+++ b/src/Provider.php
@@ -3,6 +3,7 @@
 namespace Blomstra\Search;
 
 use Blomstra\Search\Jobs\DeletingJob;
+use Blomstra\Search\Jobs\Job;
 use Blomstra\Search\Jobs\SavingJob;
 use Blomstra\Search\Seeders;
 use Elasticsearch\Client;
@@ -63,11 +64,11 @@ class Provider extends AbstractServiceProvider
         /** @var string|Seeders\Seeder $seeder */
         foreach ($seeders as $seeder) {
             $seeder::savingOn($events, function ($model) use ($queue, $seeder) {
-                $queue->push(new SavingJob(Collection::make([$model]), $seeder));
+                $queue->pushOn(Job::$onQueue, new SavingJob(Collection::make([$model]), $seeder));
             });
 
             $seeder::deletingOn($events, function ($model) use ($queue, $seeder) {
-                $queue->push(new DeletingJob(Collection::make([$model]), $seeder));
+                $queue->pushOn(Job::$onQueue, new DeletingJob(Collection::make([$model]), $seeder));
             });
         }
     }