diff --git a/app/Jobs/NodeUserSyncJob.php b/app/Jobs/NodeUserSyncJob.php index 45e8542..f49e108 100644 --- a/app/Jobs/NodeUserSyncJob.php +++ b/app/Jobs/NodeUserSyncJob.php @@ -22,7 +22,7 @@ class NodeUserSyncJob implements ShouldQueue private readonly string $action, private readonly ?int $oldGroupId = null ) { - $this->onQueue('notification'); + $this->onQueue('node_sync'); } public function handle(): void diff --git a/config/horizon.php b/config/horizon.php index 3959444..fde7487 100644 --- a/config/horizon.php +++ b/config/horizon.php @@ -60,7 +60,7 @@ return [ 'prefix' => env( 'HORIZON_PREFIX', - Str::slug(env('APP_NAME', 'laravel'), '_').'_horizon:' + Str::slug(env('APP_NAME', 'laravel'), '_') . '_horizon:' ), /* @@ -192,7 +192,7 @@ return [ ], 'notification' => [ 'connection' => 'redis', - 'queue' => ['send_email', 'send_telegram', 'send_email_mass'], + 'queue' => ['send_email', 'send_telegram', 'send_email_mass', 'node_sync'], 'balance' => 'auto', 'autoScalingStrategy' => 'size', 'minProcesses' => 1, @@ -214,6 +214,7 @@ return [ 'send_email_mass', 'send_telegram', 'user_alive_sync', + 'node_sync' ], 'balance' => 'auto', 'minProcesses' => 1,