Acknowledge reply messages after reply has been sent to corresponding…

… queue.
Workable · Jun 23, 2016 · a3fdc5f · a3fdc5f
1 parent c6fabe3
commit a3fdc5f
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/lib/queue.js b/lib/queue.js
@@ -65,17 +65,21 @@ Queue.prototype.onMessage = function(msg) {
     var body = msg.content.toString();
     var obj = JSON.parse(body);
     var hasReply = msg.properties.replyTo;
+    var ack = function () {
+      if (!this.noAck) {
+        this.channel.ack(msg);
+      }
+    }.bind(this);
 
-    if (hasReply && !this.noAck) this.channel.ack(msg);
     this.handler(obj, function(reply) {
       if (hasReply) {
         var replyBuffer = new Buffer(JSON.stringify(reply || ''));
         this.channel.sendToQueue(msg.properties.replyTo, replyBuffer, {
           correlationId: msg.properties.correlationId
-        });
+        }, ack);
       }
-      else if (!this.noAck) {
-        this.channel.ack(msg);
+      else {
+        ack();
       }
     }.bind(this), msg);
   } catch (error){