MCPcopy
hub / github.com/nats-io/nats.go / ChanQueueSubscribe

Method ChanQueueSubscribe

js.go:1545–1547  ·  view source on GitHub ↗

ChanQueueSubscribe creates channel based Subscription with a queue group. See important note in QueueSubscribe()

(subj, queue string, ch chan *Msg, opts ...SubOpt)

Source from the content-addressed store, hash-verified

1543// ChanQueueSubscribe creates channel based Subscription with a queue group.
1544// See important note in QueueSubscribe()
1545func (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()

Callers

nothing calls this directly

Calls 1

subscribeMethod · 0.95

Tested by

no test coverage detected