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

Method Next

jetstream/consumer.go:154–154  ·  view source on GitHub ↗

Next is used to retrieve the next message from the consumer. This method will block until the message is retrieved or the timeout is reached.

(opts ...FetchOpt)

Source from the content-addressed store, hash-verified

152 // method will block until the message is retrieved or the timeout
153 // is reached.
154 Next(opts ...FetchOpt) (Msg, error)
155
156 // Info fetches current ConsumerInfo from the server.
157 Info(context.Context) (*ConsumerInfo, error)

Callers 15

newAsyncReplyMethod · 0.65
subscribeMethod · 0.65
resetOrderedConsumerMethod · 0.65
newFetchInboxFunction · 0.65
PutMethod · 0.65
AddLinkMethod · 0.65
AddBucketLinkMethod · 0.65
NewInboxFunction · 0.65
NewInboxMethod · 0.65
TestWSConcurrentConnsFunction · 0.65

Implementers 2

pullConsumerjetstream/pull.go
orderedConsumerjetstream/ordered.go

Calls

no outgoing calls

Tested by 15

TestWSConcurrentConnsFunction · 0.52
TestConsumerOverflowFunction · 0.52
TestConsumerPinnedFunction · 0.52
TestConsumerUnpinFunction · 0.52
TestConsumerPrioritizedFunction · 0.52
TestScheduleAtDeliveryFunction · 0.52
TestScheduleCronDeliveryFunction · 0.52