From b7338c12d789c0819af92923b98ddc4ac9eb1be5 Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Mon, 31 Aug 2020 16:48:29 +0300
Subject: [PATCH] broker: resurrect Queue option

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 broker/options.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/broker/options.go b/broker/options.go
index 2a0bbecb..7b15828e 100644
--- a/broker/options.go
+++ b/broker/options.go
@@ -121,6 +121,12 @@ func SubscribeErrorHandler(h Handler) SubscribeOption {
 	}
 }
 
+func Queue(name string) SubscribeOption {
+	return func(o *SubscribeOptions) {
+		o.Group = name
+	}
+}
+
 // SubscribeGroup sets the name of the queue to share messages on
 func SubscribeGroup(name string) SubscribeOption {
 	return func(o *SubscribeOptions) {