ChanQueueSubscribe creates channel based Subscription with a queue group. See important note in QueueSubscribe()
(subj, queue string, ch chan *Msg, opts ...SubOpt)
| 1543 | // ChanQueueSubscribe creates channel based Subscription with a queue group. |
| 1544 | // See important note in QueueSubscribe() |
| 1545 | func (js *js) ChanQueueSubscribe(subj, queue string, ch chan *Msg, opts ...SubOpt) (*Subscription, error) { |
| 1546 | return js.subscribe(subj, queue, nil, ch, false, false, opts) |
| 1547 | } |
| 1548 | |
| 1549 | // PullSubscribe creates a Subscription that can fetch messages. |
| 1550 | // See important note in Subscribe() |