Skip to content
This repository has been archived by the owner on Dec 20, 2023. It is now read-only.

Commit

Permalink
v0.3.2
Browse files Browse the repository at this point in the history
  • Loading branch information
doug-martin committed Nov 4, 2014
1 parent d3ac887 commit dd6b8d5
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions lib/queue.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@ var comb = require("comb"),
Promise = comb.Promise,
_Options = require("./_options"),
_GetConnection = require("./_getConnection.js"),
ERROR_FORMATTER = comb("%s's listener done with error \n%s");
ERROR_FORMATTER = comb("%s's listener done with error\n");


function errorHandler(err) {
console.error(err.stack || err);
console.error(err);
throw err;
}

Expand Down Expand Up @@ -92,8 +92,8 @@ return comb.define([_Options, _GetConnection], {
when(listener.call(null, message, headers, deliveryInfo)).chain(function () {
done();
}, function (err) {
errorHandler(ERROR_FORMATTER.format(queueName, err.stack || err));
done();
errorHandler(ERROR_FORMATTER.format(queueName) + err.stack || err);
});
} else {
listener.apply(null, arguments);
Expand Down
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "hare",
"version": "0.3.1",
"version": "0.3.2",
"description": "Wrapper around amqp to make common patterns easier",
"keywords": [
"amqp",
Expand Down

0 comments on commit dd6b8d5

Please sign in to comment.