Merge pull request #30 from AnyFetch/priority

Priority on /hydrate

Author: Neamar

lib/handlers/hydrater.js

@@ -42,10 +42,10 @@ module.exports = function(req, res, server, logger, next) {
 
   // Push it to the queue
   if(req.params.long_poll) {
-    server.queue.unshift(task);
+    server.queue.push(task, -100);
   }
   else {
-    server.queue.push(task);
+    server.queue.push(task, (req.params.priority) ? -parseInt(req.params.priority) : 0);
   }
   logger("Queuing: " + ((task.file_path) ? task.file_path : task.document.id));
 };

lib/index.js

@@ -33,7 +33,7 @@ module.exports.createServer = function(config) {
   server.use(restify.queryParser());
   server.use(restify.bodyParser());
 
-  server.queue = async.queue(hydraterHelper, config.concurrency || 1);
+  server.queue = async.priorityQueue(hydraterHelper, config.concurrency || 1);
 
   // Load routes
   server.post('/hydrate', function(req, res, next) {