lkddi/Xboard
1
0
Fork 0
mirror of https://github.com/lkddi/Xboard.git synced 2026-04-03 10:30:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: correct node_sync queue assignment in horizon

Browse Source
This commit is contained in:
xboard
2026-03-16 02:28:28 +08:00
parent c45fee2a26
commit c24e09f0c7
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/Jobs/NodeUserSyncJob.php
View File

@@ -22,7 +22,7 @@ class NodeUserSyncJob implements ShouldQueue
private readonly string $action, private readonly string $action,
private readonly ?int $oldGroupId = null private readonly ?int $oldGroupId = null
) { ) {
$this->onQueue('notification'); $this->onQueue('node_sync');
} }
public function handle(): void public function handle(): void

5
config/horizon.php
View File

@@ -60,7 +60,7 @@ return [
'prefix' => env( 'prefix' => env(
'HORIZON_PREFIX', 'HORIZON_PREFIX',
Str::slug(env('APP_NAME', 'laravel'), '_').'_horizon:' Str::slug(env('APP_NAME', 'laravel'), '_') . '_horizon:'
), ),
/* /*
@@ -192,7 +192,7 @@ return [
], ],
'notification' => [ 'notification' => [
'connection' => 'redis', 'connection' => 'redis',
'queue' => ['send_email', 'send_telegram', 'send_email_mass'], 'queue' => ['send_email', 'send_telegram', 'send_email_mass', 'node_sync'],
'balance' => 'auto', 'balance' => 'auto',
'autoScalingStrategy' => 'size', 'autoScalingStrategy' => 'size',
'minProcesses' => 1, 'minProcesses' => 1,
@@ -214,6 +214,7 @@ return [
'send_email_mass', 'send_email_mass',
'send_telegram', 'send_telegram',
'user_alive_sync', 'user_alive_sync',
'node_sync'
], ],
'balance' => 'auto', 'balance' => 'auto',
'minProcesses' => 1, 'minProcesses' => 1,