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

Function OrderedConsumer

js.go:2494–2499  ·  view source on GitHub ↗

OrderedConsumer will create a FIFO direct/ephemeral consumer for in order delivery of messages. There are no redeliveries and no acks, and flow control and heartbeats will be added but will be taken care of without additional client code.

()

Source from the content-addressed store, hash-verified

2492// There are no redeliveries and no acks, and flow control and heartbeats will be added but
2493// will be taken care of without additional client code.
2494func OrderedConsumer() SubOpt {
2495 return subOptFn(func(opts *subOpts) error {
2496 opts.ordered = true
2497 return nil
2498 })
2499}
2500
2501// ManualAck disables auto ack functionality for async subscriptions.
2502func ManualAck() SubOpt {

Callers 3

WatchFilteredMethod · 0.85
GetMethod · 0.85
WatchMethod · 0.85

Calls 1

subOptFnFuncType · 0.85

Tested by

no test coverage detected