antenna-amqp - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1

lib/bus.js

@@ -76,3 +76,3 @@ /**
   var self = this;
-  this._connection = amqp.createConnection(options);
+  this._connection = amqp.createConnection(options, { reconnect: false });
   this._connection.once('ready', function() {
@@ -79,0 +79,0 @@ var exchange = options.exchange || 'amq.fanout';

lib/message.js

@@ -9,4 +9,4 @@ /**
   this.topic = deliveryInfo.routingKey.replace(/\./g, '/');
-  this.headers = {};
-  if (deliveryInfo.contentType) { headers['content-type'] = deliveryInfo.contentType; }
+  this.headers = headers;
+  if (deliveryInfo.contentType) { this.headers['content-type'] = deliveryInfo.contentType; }
   // TODO: only set body if it has been parsed, otherwise set `data`
@@ -13,0 +13,0 @@ this.body = message;

package.json

 {
   "name": "antenna-amqp",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "AMQP adapter for Antenna.",
@@ -5,0 +5,0 @@ "keywords": [

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

13641

increased by0.24%

No dependency changes