fix: pass correct config options to broker queue init

Author: adamkdean

lib/broker.js

@@ -35,10 +35,11 @@ if (config.get('env') !== 'test') {
  * that can be called when a message is received
  */
 const Broker = function (queueHandler) {
-  this.opts = config.get('broker')
+  this.brokerOpts = config.get('broker')
+  this.queueOpts = config.get('queue')
   this.queueHandler = queueHandler
-  this.rsmq = this.initialiseQueue(this.opts)
-  this.throttle = this.initialiseThrottle(this.opts)
+  this.rsmq = this.initialiseQueue(this.brokerOpts, this.queueOpts)
+  this.throttle = this.initialiseThrottle(this.brokerOpts)
 
   // message received
   this.rsmq.on('message', (msg, next) => {
@@ -60,8 +61,8 @@ const Broker = function (queueHandler) {
         message: msg.message,
         address: [],
         data: null,
-        retries: this.opts.retries - msg.rc,
-        timeout: now + this.opts.timeout,
+        retries: this.brokerOpts.retries - msg.rc,
+        timeout: now + this.brokerOpts.timeout,
         age: now + msg.sent,
         sent: msg.sent
       }
@@ -136,9 +137,9 @@ Broker.prototype.processResponse = function (req, err) {
  * @param {object} options - the set of configuration options loaded from the configuration file
  * @returns {object} - the RSMQ instance
  */
-Broker.prototype.initialiseQueue = function (options) {
+Broker.prototype.initialiseQueue = function (brokerOpts, queueOpts) {
   /* istanbul ignore next */
-  return new Rsmq(options.broker.queue, options.queue)
+  return new Rsmq(brokerOpts.queue, queueOpts)
 }
 
 /**