amqp-connection-manager
Advanced tools
Comparing version 4.1.7 to 4.1.8
@@ -557,3 +557,3 @@ "use strict"; | ||
this._reconnectConsumer(consumer).catch((err) => { | ||
if (err.isOperational && err.message.includes('BasicConsume; 404')) { | ||
if (err.code === 404) { | ||
// Ignore errors caused by queue not declared. In | ||
@@ -566,3 +566,3 @@ // those cases the connection will reconnect and | ||
} | ||
throw err; | ||
this.emit('error', err); | ||
}); | ||
@@ -569,0 +569,0 @@ return; |
@@ -529,3 +529,3 @@ import * as crypto from 'crypto'; | ||
this._reconnectConsumer(consumer).catch((err) => { | ||
if (err.isOperational && err.message.includes('BasicConsume; 404')) { | ||
if (err.code === 404) { | ||
// Ignore errors caused by queue not declared. In | ||
@@ -538,3 +538,3 @@ // those cases the connection will reconnect and | ||
} | ||
throw err; | ||
this.emit('error', err); | ||
}); | ||
@@ -541,0 +541,0 @@ return; |
{ | ||
"name": "amqp-connection-manager", | ||
"version": "4.1.7", | ||
"version": "4.1.8", | ||
"description": "Auto-reconnect and round robin support for amqplib.", | ||
@@ -5,0 +5,0 @@ "module": "./dist/esm/index.js", |
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
144312