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

Method BindRecvQueueChan

netchan.go:75–77  ·  view source on GitHub ↗

BindRecvQueueChan binds a channel for queue-based receive operations from NATS. Deprecated: Encoded connections are no longer supported.

(subject, queue string, channel any)

Source from the content-addressed store, hash-verified

73//
74// Deprecated: Encoded connections are no longer supported.
75func (c *EncodedConn) BindRecvQueueChan(subject, queue string, channel any) (*Subscription, error) {
76 return c.bindRecvChan(subject, queue, channel)
77}
78
79// Internal function to bind receive operations for a channel.
80func (c *EncodedConn) bindRecvChan(subject, queue string, channel any) (*Subscription, error) {

Callers 1

TestQueueRecvChanFunction · 0.80

Calls 1

bindRecvChanMethod · 0.95

Tested by 1

TestQueueRecvChanFunction · 0.64