broker: resurrect Queue option

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов 2020-08-31 16:48:29 +03:00
parent 7c115823a7
commit b7338c12d7

View File

@ -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) {