DeliverNew configures a Consumer to receive messages published after the subscription.
()
| 2564 | // DeliverNew configures a Consumer to receive messages |
| 2565 | // published after the subscription. |
| 2566 | func DeliverNew() SubOpt { |
| 2567 | return subOptFn(func(opts *subOpts) error { |
| 2568 | opts.cfg.DeliverPolicy = DeliverNewPolicy |
| 2569 | return nil |
| 2570 | }) |
| 2571 | } |
| 2572 | |
| 2573 | // StartSequence configures a Consumer to receive |
| 2574 | // messages from a start sequence. |
no test coverage detected