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

Method ChanQueueSubscribe

js.go:109–109  ·  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

107 // ChanQueueSubscribe creates channel based Subscription with a queue group.
108 // See important note in QueueSubscribe()
109 ChanQueueSubscribe(subj, queue string, ch chan *Msg, opts ...SubOpt) (*Subscription, error)
110
111 // QueueSubscribe creates a Subscription with a queue group.
112 // If no optional durable name nor binding options are specified, the queue name will be used as a durable name.

Callers 3

TestJetStreamSubscribeFunction · 0.65
TestChanQueueSubscriberFunction · 0.65

Calls

no outgoing calls

Tested by 3

TestJetStreamSubscribeFunction · 0.52
TestChanQueueSubscriberFunction · 0.52