Implemented "delete multiple" method

iron-io · Feb 11, 2014 · 42c981a · 42c981a
1 parent 54e25c7
commit 42c981a
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/src/api_client.coffee b/src/api_client.coffee
@@ -106,6 +106,13 @@ class APIClient extends ironCore.Client
       parseResponseBind(error, response, body, cb)
     )
 
+  messagesMultipleDelete: (queue_name, messages, cb) ->
+    parseResponseBind = _.bind(@parseResponse, @)
+
+    @delete("/#{queue_name}/messages", {ids: messages}, (error, response, body) ->
+      parseResponseBind(error, response, body, cb)
+    )
+
   messagesPeek: (queue_name, options, cb) ->
     parseResponseBind = _.bind(@parseResponse, @)
 

diff --git a/src/client.coffee b/src/client.coffee
@@ -116,6 +116,14 @@ class Client
         cb(error, body)
     )
 
+  del_multiple: (messages, cb) ->
+    @api.messagesMultipleDelete(@api.options.queue_name, messages, (error, body) ->
+      if not error?
+        cb(error, body)
+      else
+        cb(error, body)
+    )
+
   msg_get: (message_id, cb) ->
     @api.messagesGetById(@api.options.queue_name, message_id, (error, body) ->
       if not error?