servicebus - npm Package Compare versions

Comparing version 2.0.7 to 2.0.8

bus/rabbitmq/bus.js

@@ -50,2 +50,5 @@ var amqp = require('amqplib'),
 
+    conn.on('close', self.emit.bind(self, 'connection.close'));
+    conn.on('error', self.emit.bind(self, 'connection.error'));
+
     function done () {
@@ -61,2 +64,3 @@ if (self.channels.length === (options.enableConfirms ? 3 : 2)) {
       channel.on('error', channelError);
+      channel.on('close', self.emit.bind(self, 'channel.close'));
       self.sendChannel = channel;
@@ -72,2 +76,3 @@ if (options.prefetch) {
       channel.on('error', channelError);
+      channel.on('close', self.emit.bind(self, 'channel.close'));
       self.listenChannel = channel;
@@ -84,2 +89,3 @@ if (options.prefetch) {
         channel.on('error', channelError);
+        channel.on('close', self.emit.bind(self, 'channel.close'));
         self.confirmChannel = channel;
@@ -86,0 +92,0 @@ if (options.prefetch) {

package.json

@@ -10,3 +10,3 @@ {
   "description": "Simple service bus for sending events between processes using amqp.",
-  "version": "2.0.7",
+  "version": "2.0.8",
   "homepage": "https://github.com/mateodelnorte/servicebus",
@@ -13,0 +13,0 @@ "repository": {

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

62352

increased by2.31%

Number of package files

38

increased by2.7%

Lines of code

1514

increased by2.92%

Worsened metrics

Number of low supply chain risk alerts

14

increased by7.69%

No dependency changes