From 420bc8def92617d228f8bb6afa0745f70a3d8a8e Mon Sep 17 00:00:00 2001 From: Jason Campbell Date: Thu, 13 Dec 2012 10:52:40 -0800 Subject: [PATCH 1/2] Fixes #23 --- queue.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/queue.js b/queue.js index 53c03c1..e02da5d 100644 --- a/queue.js +++ b/queue.js @@ -4,7 +4,8 @@ */ var Feed = require("./feed.js").Feed, - uuid = require("node-uuid"); + uuid = require("node-uuid"), + redis = require("redis"); /** * A Thoonk queue is a typical FIFO structure, but with an From 70a889b61863e5d2f6e5e421769f09b2560f9994 Mon Sep 17 00:00:00 2001 From: Jason Campbell Date: Thu, 13 Dec 2012 12:20:11 -0800 Subject: [PATCH 2/2] Fixes #26 --- queue.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/queue.js b/queue.js index e02da5d..fecae39 100644 --- a/queue.js +++ b/queue.js @@ -62,9 +62,9 @@ function queuePublish(item, callback, priority) { id = uuid(); var multi = this.mredis.multi(); if(priority) { - multi.lpush("feed.ids:" + this.name, id); - } else { multi.rpush("feed.ids:" + this.name, id); + } else { + multi.lpush("feed.ids:" + this.name, id); } multi.hset("feed.items:" + this.name, id, item); multi.incr("feed.publishes:" + this.name);