Merge pull request #14 from dadi/feature/rsmq-init

feat: initialize queue with queue name + options
dadi · Mar 2, 2018 · b08f93b · b08f93b
2 parents 5094929 + 5544b12
commit b08f93b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/broker.js b/lib/broker.js
@@ -138,7 +138,7 @@ Broker.prototype.processResponse = function (req, err) {
  */
 Broker.prototype.initialiseQueue = function (options) {
   /* istanbul ignore next */
-  return new Rsmq(options.queue)
+  return new Rsmq(options.broker.queue, options.queue)
 }
 
 /**