pika-queue - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

index.js

@@ -20,3 +20,3 @@ "use strict";
     if (self.notify.hasOwnProperty(message.id)) {
-      self.notify[message.id].call(null, null, message.message);
+      self.notify[message.id].call(null, message.err, message.message);
       delete self.notify[message.id];
@@ -53,8 +53,9 @@ }
       var jobDescription = job.message;
-      var notificationFunc = function(data) {
-        var message = JSON.stringify({
+      var notificationFunc = function(err, data) {
+        var bundle = JSON.stringify({
           id: id,
-          message: data
+          message: data,
+          err: err
         });
-        self.notificationClient.publish('notification:' + queueName, message);
+        self.notificationClient.publish('notification:' + queueName, bundle);
       };
@@ -67,2 +68,2 @@ cb(jobDescription, notificationFunc);
 
-module.exports = PikaQueue;
+module.exports = PikaQueue;

package.json

@@ -5,3 +5,3 @@ {
   "author": "Scott Hillman <[e-mail]>",
-  "version": "0.0.6",
+  "version": "0.0.7",
   "main": "index.js",
@@ -8,0 +8,0 @@ "repository": "git://github.com/ifit/pika-queue.git",

README.md

@@ -34,5 +34,6 @@ # PikaQueue
   // Do some work...
-  notificationFunc({yourStatusMessage: "operation successful"});
+  var err = null;
+  notificationFunc(err, {yourStatusMessage: "operation successful"});
 });
 ```
 

test/pika-queue.js

@@ -14,3 +14,3 @@ var PikaQueue = require('../index')
     worker.monitorJobQueue(queueName, function(job, fn) {
-      fn({message: successMessage});
+      fn(null, {message: successMessage});
     });
@@ -44,3 +44,3 @@ setTimeout(function() {
     worker.monitorJobQueue(queueName, function(job, notificationFunc) {
-      notificationFunc({message: successMessage});
+      notificationFunc(null, {message: successMessage});
     });
@@ -77,3 +77,3 @@
     worker.monitorJobQueue(queueName, function(job, fn) {
-      fn({message: successMessage});
+      fn(null, {message: successMessage});
       done();
@@ -80,0 +80,0 @@ });

No alert changes

Improved metrics

Total package byte prevSize

5683

increased by1.27%

Number of lines in readme file

39

increased by2.63%

No dependency changes