Version 0.2.0 (add update/remove methods)

wonderlic · Apr 24, 2019 · cb193a6 · cb193a6
1 parent b649d16
commit cb193a6
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 11 deletions.
diff --git a/lib/message-queue.js b/lib/message-queue.js
@@ -126,7 +126,7 @@ function MessageQueue() {
       .then(function(status) {
         switch (status) {
           case "Completed":
-            return _removeById(queueItem._id);
+            return _removeOneById(queueItem._id);
           case "Retry":
             return _release(queueItem);
           case "Rejected":
@@ -148,10 +148,8 @@ function MessageQueue() {
       });
   }
 
-  function _removeById(id) {
-    var query = {_id: id};
-
-    return _remove(query);
+  function _removeOneById(id) {
+    return _remove({_id: id});
   }
 
   function _remove(query, multi) {
@@ -169,10 +167,8 @@ function MessageQueue() {
       });
   }
 
-  function _updateById(id, update) {
-    var query = {_id: id};
-
-    return _update(query, update);
+  function _updateOneById(id, update) {
+    return _update({_id: id}, update);
   }
 
   function _update(query, update, multi) {
@@ -209,7 +205,7 @@ function MessageQueue() {
       }
     };
 
-    return _updateById(queueItem._id, update);
+    return _updateOneById(queueItem._id, update);
   }
 
   function _reject(queueItem) {

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "mongo-message-queue",
-  "version": "0.1.4",
+  "version": "0.2.0",
   "description": "A promise based message queue for Node.js using a mongodb backing store.",
   "main": "index.js",
   "dependencies": {