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.
()
| 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. |
| 2494 | func 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. |
| 2502 | func ManualAck() SubOpt { |
no test coverage detected