From 97cbcb140f898d2758acf7f495c349268e70e2c4 Mon Sep 17 00:00:00 2001
From: Charles Abbott <cabbott@datatrac.com>
Date: Tue, 10 Jul 2018 14:59:50 -0400
Subject: [PATCH] Add kill command

---
 mongodb-queue.js | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/mongodb-queue.js b/mongodb-queue.js
index 90eb982..2ee49b9 100644
--- a/mongodb-queue.js
+++ b/mongodb-queue.js
@@ -265,3 +265,19 @@ Queue.prototype.done = function(callback) {
         callback(null, count)
     })
 }
+
+Queue.prototype.kill = function(msg, callback) {
+    var self = this
+    if ( self.deadQueue ) {
+        // 1) add this message to the deadQueue
+        // 2) ack this message from the regular queue
+        self.deadQueue.add(msg, function(err) {
+            if (err) return callback(err)
+            self.ack(msg.ack, function(err) {
+                if (err) return callback(err)
+            })
+        })
+    }
+
+    return callback(null, msg)
+}