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

Method QueueSubscribe

js.go:114–114  ·  view source on GitHub ↗

QueueSubscribe creates a Subscription with a queue group. If no optional durable name nor binding options are specified, the queue name will be used as a durable name. See important note in Subscribe()

(subj, queue string, cb MsgHandler, opts ...SubOpt)

Source from the content-addressed store, hash-verified

112 // If no optional durable name nor binding options are specified, the queue name will be used as a durable name.
113 // See important note in Subscribe()
114 QueueSubscribe(subj, queue string, cb MsgHandler, opts ...SubOpt) (*Subscription, error)
115
116 // QueueSubscribeSync creates a Subscription with a queue group that can be used to process messages synchronously.
117 // See important note in QueueSubscribe()

Callers 11

ExampleJetStreamFunction · 0.65
TestClosedConnectionsFunction · 0.65
TestQueueSubsOnReconnectFunction · 0.65
TestDrainQueueSubFunction · 0.65
ConsumeMethod · 0.65
mainFunction · 0.65
mainFunction · 0.65
mainFunction · 0.65
addEndpointFunction · 0.65

Calls

no outgoing calls

Tested by 6

ExampleJetStreamFunction · 0.52
TestClosedConnectionsFunction · 0.52
TestQueueSubsOnReconnectFunction · 0.52
TestDrainQueueSubFunction · 0.52