diff options
| author | nsfisis <nsfisis@gmail.com> | 2024-08-05 05:09:41 +0900 |
|---|---|---|
| committer | nsfisis <nsfisis@gmail.com> | 2024-08-05 05:14:30 +0900 |
| commit | 2fc239b3f4d49f1a257523df7c7781a2141252bf (patch) | |
| tree | 5b5c826e39dbc560bea29461e65a1f712382e19d /backend/main.go | |
| parent | 1325626397703567828a903a82fc1ed8626dbad4 (diff) | |
| download | phperkaigi-2025-albatross-2fc239b3f4d49f1a257523df7c7781a2141252bf.tar.gz phperkaigi-2025-albatross-2fc239b3f4d49f1a257523df7c7781a2141252bf.tar.zst phperkaigi-2025-albatross-2fc239b3f4d49f1a257523df7c7781a2141252bf.zip | |
feat(backend): implement task queue processor
Diffstat (limited to 'backend/main.go')
| -rw-r--r-- | backend/main.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/backend/main.go b/backend/main.go index a213c6c..7cfbe2f 100644 --- a/backend/main.go +++ b/backend/main.go @@ -61,7 +61,7 @@ func main() { e.Use(middleware.Recover()) taskQueue := taskqueue.NewQueue("task-db:6379") - workerServer := taskqueue.NewWorkerServer("task-db:6379") + workerServer := taskqueue.NewWorkerServer("task-db:6379", queries) gameHubs := game.NewGameHubs(queries, taskQueue) err = gameHubs.RestoreFromDB(ctx) |