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

Method AddConsumer

jsm.go:77–77  ·  view source on GitHub ↗

AddConsumer adds a consumer to a stream. If the consumer already exists, and the configuration is the same, it will return the existing consumer. If the consumer already exists, and the configuration is different, it will return ErrConsumerNameAlreadyInUse.

(stream string, cfg *ConsumerConfig, opts ...JSOpt)

Source from the content-addressed store, hash-verified

75 // If the consumer already exists, and the configuration is different, it
76 // will return ErrConsumerNameAlreadyInUse.
77 AddConsumer(stream string, cfg *ConsumerConfig, opts ...JSOpt) (*ConsumerInfo, error)
78
79 // UpdateConsumer updates an existing consumer.
80 UpdateConsumer(stream string, cfg *ConsumerConfig, opts ...JSOpt) (*ConsumerInfo, error)

Implementers 1

jsjs.go

Calls

no outgoing calls