amqp-connection-manager
Advanced tools
Comparing version 1.3.5 to 1.3.6
@@ -1,2 +0,2 @@ | ||
// Generated by CoffeeScript 1.10.0 | ||
// Generated by CoffeeScript 1.12.7 | ||
(function() { | ||
@@ -3,0 +3,0 @@ var AmqpConnectionManager, ChannelWrapper, EventEmitter, HEARTBEAT_IN_SECONDS, _, amqp, pb, urlUtils, wait, |
@@ -1,2 +0,2 @@ | ||
// Generated by CoffeeScript 1.10.0 | ||
// Generated by CoffeeScript 1.12.7 | ||
(function() { | ||
@@ -59,3 +59,3 @@ var ChannelWrapper, EventEmitter, Promise, _, pb, ref, | ||
return _this._settingUp = Promise.all(_this._setups.map(function(setupFn) { | ||
return pb.callFn(setupFn, 1, null, channel)["catch"](function(err) { | ||
return pb.call(setupFn, null, channel)["catch"](function(err) { | ||
if (_this._channel) { | ||
@@ -110,3 +110,3 @@ return _this.emit('error', err, { | ||
if (_this._channel) { | ||
return setup(_this._channel); | ||
return pb.call(setup, null, _this._channel); | ||
} | ||
@@ -122,3 +122,3 @@ }; | ||
if (_this._channel) { | ||
return pb.callFn(teardown, 1, null, _this._channel); | ||
return pb.call(teardown, null, _this._channel); | ||
} | ||
@@ -125,0 +125,0 @@ }; |
@@ -1,2 +0,2 @@ | ||
// Generated by CoffeeScript 1.10.0 | ||
// Generated by CoffeeScript 1.12.7 | ||
(function() { | ||
@@ -3,0 +3,0 @@ var Promise, ref; |
@@ -1,2 +0,2 @@ | ||
// Generated by CoffeeScript 1.10.0 | ||
// Generated by CoffeeScript 1.12.7 | ||
(function() { | ||
@@ -3,0 +3,0 @@ var AmqpConnectionManager; |
{ | ||
"name": "amqp-connection-manager", | ||
"version": "1.3.5", | ||
"version": "1.3.6", | ||
"description": "Auto-reconnect and round robin support for amqplib.", | ||
"main": "lib/index.js", | ||
"dependencies": { | ||
"es6-promise": "^3.0.2", | ||
"es6-promise": "^4.1.1", | ||
"lodash": "^4.15.0", | ||
"promise-breaker": "^3.0.0", | ||
"promise-breaker": "^4.1.2", | ||
"when": "^3.7.3" | ||
@@ -16,12 +16,13 @@ }, | ||
"devDependencies": { | ||
"chai": "^3.4.1", | ||
"chai-as-promised": "^5.1.0", | ||
"amqplib": "^0.5.1", | ||
"chai": "^4.1.2", | ||
"chai-as-promised": "^7.1.1", | ||
"chai-string": "^1.1.2", | ||
"coffee-coverage": "^1.0.1", | ||
"coffee-coverage": "^2.0.1", | ||
"coffee-script": "^1.9.3", | ||
"coveralls": "^2.11.4", | ||
"coveralls": "^3.0.0", | ||
"istanbul": "^0.4.0", | ||
"mocha": "^2.2.5", | ||
"mocha": "^4.0.1", | ||
"proxyquire": "^1.7.0", | ||
"sinon": "^1.16.1" | ||
"sinon": "^4.0.1" | ||
}, | ||
@@ -33,3 +34,3 @@ "scripts": { | ||
"distclean": "npm run clean && rm -rf node_modules", | ||
"test": "mocha && istanbul report text-summary lcov" | ||
"test": "mocha \"test/**/*.{js,coffee}\" && istanbul report text-summary lcov" | ||
}, | ||
@@ -36,0 +37,0 @@ "repository": { |
@@ -47,3 +47,3 @@ [![Build Status](https://travis-ci.org/benbria/node-amqp-connection-manager.svg?branch=master)](https://travis-ci.org/benbria/node-amqp-connection-manager) | ||
// Create a new connection manager | ||
var connection = amqp.connect(['amqp://localhost'], {json: true}); | ||
var connection = amqp.connect(['amqp://localhost']); | ||
@@ -53,2 +53,3 @@ // Ask the connection manager for a ChannelWrapper. Specify a setup function to run every time we reconnect | ||
var channelWrapper = connection.createChannel({ | ||
json: true, | ||
setup: function(channel) { | ||
@@ -55,0 +56,0 @@ // `channel` here is a regular amqplib `ConfirmChannel`. |
Sorry, the diff of this file is not supported yet
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
27087
9
180
11
+ Addedes6-promise@4.2.8(transitive)
+ Addedpromise-breaker@4.1.13(transitive)
- Removedes6-promise@3.3.1(transitive)
- Removedpromise-breaker@3.0.0(transitive)
Updatedes6-promise@^4.1.1
Updatedpromise-breaker@^4.1.2