Merge pull request #50 from XescuGC/resque_queues

Add the SADD to register a queue after using enqueue
benmanns · Mar 29, 2017 · 5e68afb · 5e68afb
2 parents feec08d + cf76893
commit 5e68afb
Showing 1 changed file with 7 additions and 0 deletions.
diff --git 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 register queue to list of use queues")
+		return err
+	}
+
 	return conn.Flush()
 }