svcs - npm Package Compare versions

Comparing version 0.1.8 to 0.1.9

lib/route/index.js

@@ -16,2 +16,3 @@ 'use strict';
   queue: 'queue123', // todo routeToQueueName(route)
+  queueOpts: {durable: true, autoDelete: false, messageTtl: 30000, expires: 3600000},
   autoAck: false
@@ -92,3 +93,3 @@ };
       ch.assertExchange(self.options.exchange, 'topic'),
-      ch.assertQueue(self.options.queue),
+      ch.assertQueue(self.options.queue, self.options.queueOpts),
       ch.bindQueue(self.options.queue, self.options.exchange, routingKey),
@@ -95,0 +96,0 @@ ch.consume(self.options.queue, handleMessage, {consumerTag: self.consumerTag})

package.json

 {
   "name": "svcs",
-  "version": "0.1.8",
+  "version": "0.1.9",
   "description": "AMQP driven micro services for node.",
@@ -5,0 +5,0 @@ "main": "index.js",

test/container_test.js

@@ -40,3 +40,2 @@ 'use strict';
           ok = ok.then(function (ch) {
-            ch.assertQueue('test_events_params');
             ch.publish('amq.topic', '$test.123456.events.some', new Buffer(JSON.stringify({msg: 'some message'})), {contentType: 'application/json'});
@@ -43,0 +42,0 @@ });

test/middleware/json_test.js

@@ -70,3 +70,2 @@ 'use strict';
           ok = ok.then(function (ch) {
-            ch.assertQueue('test_events_json');
             ch.publish('amq.topic', '$jsontest.123456.events', new Buffer(JSON.stringify({msg: 'some message'})), {contentType: 'application/json'});
@@ -73,0 +72,0 @@ });

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

21445

increased by0.06%

Worsened metrics

Lines of code

532

decreased by-0.19%

No dependency changes