Merge pull request #5 from reedsy/add-deleted-index

⚡ Add deleted index

Author: dawidreedsy

mongodb-queue.js

@@ -58,7 +58,10 @@ Queue.prototype.createIndexes = function(callback) {
         if (err) return callback(err)
         self.col.createIndex({ ack : 1 }, { unique : true, sparse : true }, function(err) {
             if (err) return callback(err)
-            callback(null, indexname)
+            self.col.createIndex({ deleted : 1 }, { sparse : true }, function(err) {
+                if (err) return callback(err)
+                callback(null, indexname)
+            })
         })
     })
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@reedsy/mongodb-queue",
-  "version": "4.0.0-reedsy-2.0.0",
+  "version": "4.0.0-reedsy-2.0.1",
   "description": "Message queues which uses MongoDB.",
   "main": "mongodb-queue.js",
   "scripts": {