add priority to queue items

wonderlic · Dec 12, 2018 · 8a3d08f · 8a3d08f
1 parent 7e8494f
commit 8a3d08f
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;