Socket
Socket
Sign inDemoInstall

amqp-connection-manager

Package Overview
Dependencies
Maintainers
12
Versions
67
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

amqp-connection-manager - npm Package Compare versions

Comparing version 1.3.5 to 1.3.6

CHANGELOG.md

2

lib/AmqpConnectionManager.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc