Comparing version 5.8.1 to 5.8.2
@@ -296,6 +296,5 @@ | ||
const options = this._workerOptions[exchange] || {}; | ||
const queueOptions = options.queueOptions; | ||
return this._rabbitmq.subscribeToFanoutExchange(exchange, (job, jobMeta, done) => { | ||
this._enqueue(exchange, worker, job, jobMeta, done); | ||
}, queueOptions); | ||
}, options); | ||
}); | ||
@@ -302,0 +301,0 @@ }).return(); |
{ | ||
"name": "ponos", | ||
"version": "5.8.1", | ||
"version": "5.8.2", | ||
"description": "An opinionated queue based worker server for node.", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
77813
1570