Merge pull request #2 from wonderlic-stevend/feature/priority

add priority to queue items
wonderlic · Dec 18, 2018 · aea77e9 · aea77e9
2 parents 7e8494f + 8a3d08f
commit aea77e9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/message-queue.js b/lib/message-queue.js
@@ -37,6 +37,10 @@ function MessageQueue() {
     if (options && options.nextReceivableTime) {
       queueItem.nextReceivableTime = options.nextReceivableTime;
     }
+
+    // The priority range is 1-10, 1 being the highest.
+    queueItem.priority = _.get(options, 'priority', 1);
+
     return _enqueue(queueItem);
   };
 
@@ -216,7 +220,7 @@ function MessageQueue() {
     if (!self.databasePromise) { return Q.reject(new Error("No database configured")); }
     return self.databasePromise()
       .then(function(db) {
-        return db.collection(self.collectionName).findOneAndUpdate(query, update, {returnOriginal: false});
+        return db.collection(self.collectionName).findOneAndUpdate(query, update, {returnOriginal: false, sort: 'priority'});
       })
       .then(function(result) {
         return result.value;