From e4ef9aa9510f0f164010193f8f946cbc967137c3 Mon Sep 17 00:00:00 2001 From: xescuGC Date: Tue, 21 Feb 2017 19:02:25 +0100 Subject: [PATCH 1/2] Add the SADD to register a queue after using enqueue --- workers.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/workers.go b/workers.go index 39415d3..352922e 100644 --- a/workers.go +++ b/workers.go @@ -39,11 +39,18 @@ func Enqueue(job *Job) error { logger.Criticalf("Cant marshal payload on enqueue") return err } + err = conn.Send("RPUSH", fmt.Sprintf("%squeue:%s", workerSettings.Namespace, job.Queue), buffer) if err != nil { logger.Criticalf("Cant push to queue") return err } + err = conn.Send("SADD", fmt.Sprintf("%squeues", workerSettings.Namespace), job.Queue) + if err != nil { + logger.Criticalf("Cant regiser queue to list of use queues") + return err + } + return conn.Flush() } From cf768936440196a3d953e4bb8fb54ca045367a91 Mon Sep 17 00:00:00 2001 From: xescuGC Date: Wed, 29 Mar 2017 08:51:48 +0200 Subject: [PATCH 2/2] Misspell: regiser -> register --- workers.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/workers.go b/workers.go index 352922e..0a5fb6f 100644 --- a/workers.go +++ b/workers.go @@ -48,7 +48,7 @@ func Enqueue(job *Job) error { err = conn.Send("SADD", fmt.Sprintf("%squeues", workerSettings.Namespace), job.Queue) if err != nil { - logger.Criticalf("Cant regiser queue to list of use queues") + logger.Criticalf("Cant register queue to list of use queues") return err }