From 2fc239b3f4d49f1a257523df7c7781a2141252bf Mon Sep 17 00:00:00 2001 From: nsfisis Date: Mon, 5 Aug 2024 05:09:41 +0900 Subject: feat(backend): implement task queue processor --- backend/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'backend/main.go') 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) -- cgit v1.2.3-70-g09d2