remit - npm Package Compare versions

Comparing version 1.0.8 to 1.0.9

index.js

@@ -60,8 +60,11 @@ 'use strict'
 
-            queue.subscribe(function (msg, d, headers, info) {
+            queue.subscribe({
+                ack: true,
+                prefetchCount: 0
+            }, function (message, headers, deliveryInfo, messageObject) {
                 let event_info = {
-                    event: info.routingKey,
-                    exchange: info.exchange,
-                    contentType: info.contentType,
-                    size: info.size
+                    event: messageObject.routingKey,
+                    exchange: messageObject.exchange,
+                    contentType: messageObject.contentType,
+                    size: messageObject.size
                 }
@@ -71,5 +74,7 @@
 
-                if (!info.correlationId || !info.replyTo) {
+                if (!messageObject.correlationId || !messageObject.replyTo) {
                     try {
-                        callback(context, msg, null, event_info)
+                        messageObject.acknowledge()
+
+                        callback(context, message, null, event_info)
                     } catch (e) {
@@ -84,6 +89,8 @@ if (self.on_error) {
                     try {
-                        callback.call(context, msg, function (err, data) {
-                            let options = {correlationId: info.correlationId}
+                        callback.call(context, message, function (err, data) {
+                            let options = {correlationId: messageObject.correlationId}
 
-                            self._exchange.publish(info.replyTo, Array.prototype.slice.call(arguments), options)
+                            self._exchange.publish(messageObject.replyTo, Array.prototype.slice.call(arguments), options)
+
+                            messageObject.acknowledge()
                         })
@@ -90,0 +97,0 @@ } catch (e) {

package.json

 {
   "name": "remit",
-  "version": "1.0.8",
+  "version": "1.0.9",
   "description": "`remit` is intended to be a small set of functionality used to create simple microservices that don't need to be aware of one-another's existence.",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

16842

increased by1.76%

Lines of code

279

increased by1.82%

No dependency changes