Support multiple notification push workers

This commit is contained in:
2024-07-22 01:28:18 +08:00
parent b0735a7514
commit d64743162f
2 changed files with 6 additions and 1 deletions

View File

@ -42,7 +42,9 @@ func main() {
}
// Set up tasks queue consumers
go services.ConsumeDeliveryTasks()
for idx := 0; idx < max(1, viper.GetInt("performance.notification_deliver.worker_count")); idx++ {
go services.ConsumeDeliveryTasks()
}
// Server
go server.NewServer().Listen()