node-queue-bus - npm Package Compare versions

Comparing version 0.0.5 to 0.0.6

package.json

@@ -5,3 +5,3 @@ {
   "description": "an implementation of queuebus in node",
-  "version": "0.0.5",
+  "version": "0.0.6",
   "homepage": "http://github.com/queuebus/node-queue-bus",
@@ -8,0 +8,0 @@ "repository": {

readme.md

 # node-queue-bus
 
-[![Nodei stats](https://nodei.co/npm/node-queuebus.png?downloads=true)](https://npmjs.org/package/node-queue-bus)
+[![Nodei stats](https://nodei.co/npm/node-queue-bus.png?downloads=true)](https://npmjs.org/package/node-queue-bus)
 
-[![Build Status](https://travis-ci.org/taskrabbit/node-queuebus.png?branch=master)](https://travis-ci.org/queue-bus/node-queuebus)
+[![Build Status](https://travis-ci.org/queue-bus/node-queue-bus.png?branch=master)](https://travis-ci.org/queue-bus/node-queuebus)
 
@@ -138,2 +138,2 @@ ## Acknowledgments
 
-You can see a full example with workers, riders, and schedulers in [/examples/example.js](https://github.com/queue-bus/node-queue-bus/blob/examples/example.js)
+You can see a full example with workers, riders, and schedulers in [/examples/example.js](https://github.com/queue-bus/node-queue-bus/blob/examples/example.js)

test/publish.js

@@ -37,10 +37,11 @@ var specHelper = require(__dirname + "/_specHelper.js").specHelper;
         elem = JSON.parse(elem);
+        var payload = JSON.parse(elem.args[0]);
         elem.class.should.equal("QueueBus::Worker");
-        elem.args[0].bus_class_proxy.should.equal("QueueBus::Driver");
+        payload.bus_class_proxy.should.equal("QueueBus::Driver");
         elem.queue.should.equal("bus_incoming");
-        elem.args[0].thing.should.equal('stuff');
-        elem.args[0].bus_event_type.should.equal("testEvent");
-        elem.args[0].bus_published_at.should.equal(now);
-        should.exist(elem.args[0].bus_id);
-        elem.args[0].bus_app_hostname.should.equal(os.hostname());
+        payload.thing.should.equal('stuff');
+        payload.bus_event_type.should.equal("testEvent");
+        payload.bus_published_at.should.equal(now);
+        should.exist(payload.bus_id);
+        payload.bus_app_hostname.should.equal(os.hostname());
         done();
@@ -61,4 +62,5 @@ });
           elem = JSON.parse(elem);
+          var payload = JSON.parse(elem.args[0]);
           elem.class.should.equal("QueueBus::Worker");
-          elem.args[0].bus_class_proxy.should.equal("QueueBus::Publisher");
+          payload.bus_class_proxy.should.equal("QueueBus::Publisher");
           elem.queue.should.equal("bus_incoming");
@@ -81,4 +83,5 @@ done();
           elem = JSON.parse(elem);
+          var payload = JSON.parse(elem.args[0]);
           elem.class.should.equal("QueueBus::Worker");
-          elem.args[0].bus_class_proxy.should.equal("QueueBus::Publisher");
+          payload.bus_class_proxy.should.equal("QueueBus::Publisher");
           elem.queue.should.equal("bus_incoming");
@@ -102,6 +105,7 @@ done();
             elem = JSON.parse(elem);
+            var payload = JSON.parse(elem.args[0]);
             elem.class.should.equal("QueueBus::Worker");
-            elem.args[0].bus_class_proxy.should.equal("QueueBus::Publisher");
+            payload.bus_class_proxy.should.equal("QueueBus::Publisher");
             elem.queue.should.equal("bus_incoming");
-            elem.args[0].thing.should.equal('stuff');
+            payload.thing.should.equal('stuff');
             scheduler.end(function(){
@@ -108,0 +112,0 @@ done();

test/rider.js

@@ -91,8 +91,9 @@ var specHelper = require(__dirname + "/_specHelper.js").specHelper;
             var e = JSON.parse(data.a);
-            should.exist(e.args[0].bus_driven_at);
-            e.args[0].bus_rider_queue.should.equal('app_a_default');
-            e.args[0].bus_rider_app_key.should.equal('app_a');
-            e.args[0].bus_rider_sub_key.should.equal('app_a_default_job_a');
-            e.args[0].bus_rider_class_name.should.equal('job_a');
-            e.args[0].bus_event_type.should.equal('event_a');
+            var paylaod = JSON.parse(e.args[0]);
+            should.exist(paylaod.bus_driven_at);
+            paylaod.bus_rider_queue.should.equal('app_a_default');
+            paylaod.bus_rider_app_key.should.equal('app_a');
+            paylaod.bus_rider_sub_key.should.equal('app_a_default_job_a');
+            paylaod.bus_rider_class_name.should.equal('job_a');
+            paylaod.bus_event_type.should.equal('event_a');
             done();
@@ -99,0 +100,0 @@ });

No alert changes

Improved metrics

Total package byte prevSize

188867

increased by0.1%

Lines of code

967

increased by0.52%

Number of lines in readme file

139

increased by0.72%

No dependency changes