From 6f6c6e371d43a230a3172ffb12fc8d766e8a99b6 Mon Sep 17 00:00:00 2001
From: waroom <759325100@qq.com>
Date: Tue, 8 Aug 2017 16:01:20 +0800
Subject: [PATCH] Add the subSocket custom queue name function

I have a need for multiple programs to consume a queue together, so I need to customize the queue name, and exclusive = false
---
 lib/sockets.js | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/lib/sockets.js b/lib/sockets.js
index 27f13ec..be53007 100644
--- a/lib/sockets.js
+++ b/lib/sockets.js
@@ -220,8 +220,8 @@ function SubSocket(channel, opts) {
   var self = this;
 
   var setup = channel.then(function(ch) {
-    return ch.assertQueue('', {
-      exclusive: true, autoDelete: true
+    return ch.assertQueue(self.options.queue || '', {
+      exclusive: (self.options.queue?false:true), autoDelete: true
     }).then(function(ok) {
       self.queue = ok.queue; // for inspection
       return ch.consume(ok.queue, function(msg) {