amqp-connection-manager
Advanced tools
Comparing version 1.3.7 to 1.4.0
@@ -0,1 +1,6 @@ | ||
1.4.0 | ||
----- | ||
* Add 'blocked' and 'unblocked' events (#25). | ||
1.3.7 | ||
@@ -2,0 +7,0 @@ ----- |
@@ -118,2 +118,10 @@ // Generated by CoffeeScript 1.12.7 | ||
_this._currentConnection = connection; | ||
connection.on('blocked', function(reason) { | ||
return _this.emit('blocked', { | ||
reason: reason | ||
}); | ||
}); | ||
connection.on('unblocked', function() { | ||
return _this.emit('unblocked'); | ||
}); | ||
connection.on('error', function(err) { | ||
@@ -120,0 +128,0 @@ return Promise.resolve().then(function() { |
{ | ||
"name": "amqp-connection-manager", | ||
"version": "1.3.7", | ||
"version": "1.4.0", | ||
"description": "Auto-reconnect and round robin support for amqplib.", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
@@ -136,3 +136,2 @@ [![Build Status](https://travis-ci.org/benbria/node-amqp-connection-manager.svg?branch=master)](https://travis-ci.org/benbria/node-amqp-connection-manager) | ||
* `error(err, {name})` - emitted if an error occurs setting up the channel. | ||
* `drop({message, err})` - called when a JSON message was dropped because it could not be encoded. | ||
* `close` - emitted when this channel closes via a call to `close()` | ||
@@ -139,0 +138,0 @@ |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
27456
447
179