amqp-as-promised
Advanced tools
Comparing version 1.2.5 to 2.0.0
@@ -39,3 +39,8 @@ // Generated by CoffeeScript 1.10.0 | ||
if (!isShutdown) { | ||
return log.warn('amqp error:', (err.message ? err.message : err)); | ||
log.warn('amqp error:', (err.message ? err.message : err)); | ||
if (typeof (conf != null ? conf.errorHandler : void 0) === 'function') { | ||
return conf.errorHandler(err); | ||
} else { | ||
throw err; | ||
} | ||
} | ||
@@ -42,0 +47,0 @@ }); |
{ | ||
"name": "amqp-as-promised", | ||
"description": "A promise-based AMQP API build on node-amqp", | ||
"version": "1.2.5", | ||
"version": "2.0.0", | ||
"repository": { | ||
@@ -6,0 +6,0 @@ "type": "git", |
@@ -63,2 +63,9 @@ AMQP as Promised | ||
### `errorHandler` | ||
*Since 2.0* connection errors are rethrown to crash process. | ||
* `errorHandler`: sets a handler function to receive the error instead of | ||
throwing to process. | ||
## Example config | ||
@@ -65,0 +72,0 @@ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
92992
31
762
362