diff --git a/app/Domains/Real/Commands/Sync/MongoSync.php b/app/Domains/Real/Commands/Sync/MongoSync.php index 0211b901..b19ea6e6 100644 --- a/app/Domains/Real/Commands/Sync/MongoSync.php +++ b/app/Domains/Real/Commands/Sync/MongoSync.php @@ -47,13 +47,15 @@ class MongoSync extends Command break; } - $jobs->push((new MongoSyncJob($page, $this->limit, $utcDateTime))->onQueue('sync')); + $jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime)); } app(ConfigService::class)->set(self::CURSOR_KEY, intval($nextMicrotime)); - if ($total) { - MongoSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $utcDateTime); - } + $total && dispatch($job); + + $total && MongoSyncJob::withChain($jobs->toArray()) + ->dispatch(1, $this->limit, $utcDateTime) + ->allOnQueue('sync'); } } diff --git a/app/Domains/Virtual/Commands/Sync/CardSync.php b/app/Domains/Virtual/Commands/Sync/CardSync.php index 99777e16..8d18f6b0 100644 --- a/app/Domains/Virtual/Commands/Sync/CardSync.php +++ b/app/Domains/Virtual/Commands/Sync/CardSync.php @@ -50,11 +50,13 @@ class CardSync extends Command break; } - $jobs->push((new CardSyncJob($page, $this->limit, $maxId))->onQueue('sync')); + $jobs->push(new CardSyncJob($page, $this->limit, $maxId)); } $nextId && app(ConfigService::class)->set(self::CURSOR_KEY, $nextId); - $total && CardSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId); + $total && CardSyncJob::withChain($jobs->toArray()) + ->dispatch(1, $this->limit, $maxId) + ->allOnQueue('sync'); } } diff --git a/app/Domains/Virtual/Commands/Sync/LogSync.php b/app/Domains/Virtual/Commands/Sync/LogSync.php index 9d8e15e7..bd40a445 100644 --- a/app/Domains/Virtual/Commands/Sync/LogSync.php +++ b/app/Domains/Virtual/Commands/Sync/LogSync.php @@ -56,11 +56,13 @@ class LogSync extends Command break; } - $jobs->push((new LogSyncJob($page, $this->limit, $maxId))->onQueue('sync')); + $jobs->push(new LogSyncJob($page, $this->limit, $maxId)); } $nextId && app(ConfigService::class)->set(self::CURSOR_KEY, $nextId); - $total && LogSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId); + $total && LogSyncJob::withChain($jobs->toArray()) + ->dispatch(1, $this->limit, $maxId) + ->allOnQueue('sync'); } }