PullSubscribe creates a Subscription that can fetch messages. See important note in Subscribe()
(subj, durable string, opts ...SubOpt)
| 1549 | // PullSubscribe creates a Subscription that can fetch messages. |
| 1550 | // See important note in Subscribe() |
| 1551 | func (js *js) PullSubscribe(subj, durable string, opts ...SubOpt) (*Subscription, error) { |
| 1552 | mch := make(chan *Msg, js.nc.Opts.SubChanLen) |
| 1553 | if durable != "" { |
| 1554 | opts = append(opts, Durable(durable)) |
| 1555 | } |
| 1556 | return js.subscribe(subj, _EMPTY_, nil, mch, true, true, opts) |
| 1557 | } |
| 1558 | |
| 1559 | func processConsInfo(info *ConsumerInfo, userCfg *ConsumerConfig, isPullMode bool, subj, queue string) (string, error) { |
| 1560 | ccfg := &info.Config |