Skip to content
This repository has been archived by the owner on Aug 31, 2021. It is now read-only.

Commit

Permalink
🚿 Clean up worker channel creation
Browse files Browse the repository at this point in the history
  • Loading branch information
jpwilliams committed Jul 17, 2017
1 parent 7b7367c commit d4b7328
Showing 1 changed file with 2 additions and 8 deletions.
10 changes: 2 additions & 8 deletions lib/assertions/bootWorkChannelPool.js
Original file line number Diff line number Diff line change
Expand Up @@ -11,14 +11,8 @@ function bootChannelPool () {
connect.apply(remit).then((connection) => {
return connection.createChannel()
}).then((channel) => {
channel.on('error', (err) => {
debug(err.message)
})

channel.on('close', () => {
debug('Worker channel closed')
})

channel.on('error', err => debug(err.message))
channel.on('close', () => debug('Worker channel closed'))
resolve(channel)
}).catch(reject)
})
Expand Down

0 comments on commit d4b7328

Please sign in to comment.