From 2301bd5439ebf075bd5c51e07fa0e9c984b61cfb Mon Sep 17 00:00:00 2001 From: utestmig Date: Wed, 3 Sep 2014 12:17:05 -0400 Subject: [PATCH 1/2] Passing 'autoDelete' option to assertQueue for a 'REP' socket --- lib/sockets.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/sockets.js b/lib/sockets.js index b793962..14123e9 100644 --- a/lib/sockets.js +++ b/lib/sockets.js @@ -458,7 +458,7 @@ RepSocket.prototype.connect = function(source, callback) { delay(callback); return; } - ch.assertQueue(source, {durable: this.options.persistent}) + ch.assertQueue(source, {durable: this.options.persistent, autoDelete: this.options.autoDelete || false}) .then(function(ok) { return ch.consume(source, function(msg) { if (msg !== null) { From fd4ec3de18b7a4bc9dd3255341584781a908a201 Mon Sep 17 00:00:00 2001 From: utestmig Date: Thu, 4 Sep 2014 08:51:30 -0400 Subject: [PATCH 2/2] Passing 'autoDelete' option to assertQueue for a 'REQ' socket --- lib/sockets.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/sockets.js b/lib/sockets.js index 14123e9..449f4ee 100644 --- a/lib/sockets.js +++ b/lib/sockets.js @@ -415,7 +415,7 @@ ReqSocket.prototype.handleReply = function(msg) { ReqSocket.prototype.connect = function(destination, callback) { var self = this, ch = this.ch; - ch.assertQueue(destination, {durable: this.options.persistent}) + ch.assertQueue(destination, {durable: this.options.persistent, autoDelete: this.options.autoDelete || false}) .then(function(ok) { self.queues.push(ok.queue); }).then(callback);