From 11cc2849c25300904cef488c9f7f5439a44792c5 Mon Sep 17 00:00:00 2001
From: Ryan Milbourne <Ryan.Milbourne@viasat.com>
Date: Sun, 25 Oct 2015 14:44:33 -0700
Subject: [PATCH] Fix `on()` queue option handling

This commit fixes an issue where the on() function prototype was not
creating its queue with the options passed to it (exclusive, durable,
autoDelete).  The code is modified to create an object that is passed to
the amqp library.  The option contains the properties durable, exclusive
and autoDelete.

Defaults match node-amqp's defaults.

Tested against node-amqp 0.2.4 and RabbitMQ 3.3.5
---
 index.js     | 11 +++++++++--
 package.json |  2 +-
 2 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/index.js b/index.js
index 44c965f..83eeddf 100644
--- a/index.js
+++ b/index.js
@@ -276,13 +276,15 @@ rpc.prototype.call = function(cmd, params, cb, context, options) {
  *                                    Non-durable queues (transient queues) are purged if/when a server restarts.
  *                                    Note that durable queues do not necessarily hold persistent messages,
  *                                    although it does not make sense to send persistent messages to a transient queue.
-
+ *                                    Defaults to false.
  * @param {boolean} options.exclusive Exclusive queues may only be accessed by the current connection,
  *                                    and are deleted when that connection closes.
+ *                                    Defaults to false.
  * @param {boolean} options.autoDelete If true, the queue is deleted when all consumers have finished using it.
  *                                     The last consumer can be cancelled either explicitly or because its channel is closed.
  *                                     If there was no consumer ever on the queue, it won't be deleted. Applications
  *                                     can explicitly delete auto-delete queues using the Delete method as normal.
+ *                                     Defaults to true.
  * @return {boolean}
  */
 
@@ -292,11 +294,16 @@ rpc.prototype.on = function(cmd, cb, context, options)    {
     if(this.__cmds[ cmd ]) return false;
     options || (options = {});
 
+    var durable = (typeof options.durable === 'undefined' ? false : options.durable)
+      , exclusive = (typeof options.exclusive === 'undefined' ? false : options.exclusive)
+      , autoDelete = (typeof options.autoDelete === 'undefined' ? true : options.autoDelete)
+    ;
+
     var $this = this;
 
     this._connect(function()    {
 
-        $this.__conn.queue(options.queueName || cmd, function(queue) {
+        $this.__conn.queue(options.queueName || cmd, {durable: durable, exclusive: exclusive, autoDelete: autoDelete}, function(queue) {
             $this.__cmds[ cmd ] = { queue: queue };
             queue.subscribe(function(message, d, headers, deliveryInfo)  {
 
diff --git a/package.json b/package.json
index ff0a711..9cd3979 100644
--- a/package.json
+++ b/package.json
@@ -5,7 +5,7 @@
     "amqp",
     "rpc"
   ],
-  "version": "0.0.8",
+  "version": "0.0.9",
   "preferGlobal": true,
   "author": {
     "name": "Eugene Demchenko"