Skip to content

Commit de7b8ae

Browse files
author
Tom Kirkpatrick
committed
fix: log rejections with debug
1 parent 43ac18b commit de7b8ae

File tree

3 files changed

+3
-5
lines changed

3 files changed

+3
-5
lines changed

lib/mixins/message-queue.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,16 +31,16 @@ module.exports = function messageQueueMixin(Model, options) {
3131
try {
3232
return Model[name](msg.body, msg)
3333
.then(() => {
34-
debug('consumer %s ran successfully for model %s. key: %o',
35-
name, Model.modelName, msg.fields.routingKey)
34+
debug('consumer %s ran successfully for model %s. key: %o', name, Model.modelName, msg.fields.routingKey)
3635
return msg.ack()
3736
})
3837
.catch(err => {
39-
RabbitMQ.log.error(err)
38+
debug(`consumer ${name} failed ${Model.modelName}. key: ${msg.fields.routingKey}: %o`, err)
4039
return msg.nack()
4140
})
4241
}
4342
catch (err) {
43+
debug(`consumer ${name} failed ${Model.modelName}. key: ${msg.fields.routingKey}: %o`, err)
4444
RabbitMQ.log.error(err)
4545
return msg.nack()
4646
}

test/common.js

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ global.sinonChai = require('sinon-chai')
66

77
global.expect = global.chai.expect
88

9-
require('sinon-as-promised')
109
require('mocha-sinon')()
1110

1211
global.chai.use(require('dirty-chai'))

test/mixin.test.js

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
require('./common')
44

55
const path = require('path')
6-
const rabbit = require('rabbot')
76
const requireUncached = require('./common').requireUncached
87

98
const TEST_APP = path.join(__dirname, 'fixtures/test-server/server.js')

0 commit comments

Comments
 (0)