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

Method ResumeConsumer

jetstream/stream.go:110–110  ·  view source on GitHub ↗

ResumeConsumer resumes a consumer.

(ctx context.Context, consumer string)

Source from the content-addressed store, hash-verified

108
109 // ResumeConsumer resumes a consumer.
110 ResumeConsumer(ctx context.Context, consumer string) (*ConsumerPauseResponse, error)
111
112 // ListConsumers returns ConsumerInfoLister enabling iterating over a
113 // channel of consumer infos.

Callers 2

TestJetStreamPauseAndResumeConsumerFunction · 0.65
TestPauseConsumerFunction · 0.65

Implementers 1

streamjetstream/stream.go

Calls

no outgoing calls

Tested by 2

TestJetStreamPauseAndResumeConsumerFunction · 0.52
TestPauseConsumerFunction · 0.52