diff --git a/app/Domains/Real/Commands/Sync/MongoSync.php b/app/Domains/Real/Commands/Sync/MongoSync.php index 841548ee..25182dd2 100644 --- a/app/Domains/Real/Commands/Sync/MongoSync.php +++ b/app/Domains/Real/Commands/Sync/MongoSync.php @@ -47,11 +47,11 @@ class MongoSync extends Command break; } - $jobs->push(new MongoSyncJob($page, $this->limit, $utcDateTime)); + $jobs->push((new MongoSyncJob($page, $this->limit, $utcDateTime))->onQueue('sync')); } app(ConfigService::class)->set(self::CURSOR_KEY, intval($nextMicrotime)); - MongoSyncJob::withChain($jobs->toArray())->dispatch(1, $this->limit, $utcDateTime); + MongoSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $utcDateTime); } } diff --git a/app/Domains/Virtual/Commands/Sync/CardSync.php b/app/Domains/Virtual/Commands/Sync/CardSync.php index 9b9fd21f..d38e48bc 100644 --- a/app/Domains/Virtual/Commands/Sync/CardSync.php +++ b/app/Domains/Virtual/Commands/Sync/CardSync.php @@ -50,11 +50,11 @@ class CardSync extends Command break; } - $jobs->push(new CardSyncJob($page, $this->limit, $maxId)); + $jobs->push((new CardSyncJob($page, $this->limit, $maxId))->onQueue('sync')); } app(ConfigService::class)->set(self::CURSOR_KEY, $nextId); - CardSyncJob::withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId); + CardSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId); } } diff --git a/app/Domains/Virtual/Commands/Sync/LogSync.php b/app/Domains/Virtual/Commands/Sync/LogSync.php index 53b0fd5e..0b554111 100644 --- a/app/Domains/Virtual/Commands/Sync/LogSync.php +++ b/app/Domains/Virtual/Commands/Sync/LogSync.php @@ -55,11 +55,11 @@ class LogSync extends Command break; } - $jobs->push(new LogSyncJob($page, $this->limit, $maxId)); + $jobs->push((new LogSyncJob($page, $this->limit, $maxId))->onQueue('sync')); } app(ConfigService::class)->set(self::CURSOR_KEY, $nextId); - LogSyncJob::withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId); + LogSyncJob::onQueue('sync')->withChain($jobs->toArray())->dispatch(1, $this->limit, $maxId); } } diff --git a/etc/supervisor.conf b/etc/supervisor.conf new file mode 100644 index 00000000..987e0c4d --- /dev/null +++ b/etc/supervisor.conf @@ -0,0 +1,9 @@ +[program:vd-worker] +process_name=%(program_name)s_%(process_num)02d +command=php /www/vd/artisan queue:work --queue=default,sync --sleep=3 --tries=1 --memory=4096 +autostart=true +autorestart=true +user=denghy +numprocs=2 +redirect_stderr=true +stdout_logfile=/dev/null