DeliverLastPerSubject configures a Consumer to receive messages starting with the latest one for each filtered subject.
()
| 2555 | // DeliverLastPerSubject configures a Consumer to receive messages |
| 2556 | // starting with the latest one for each filtered subject. |
| 2557 | func DeliverLastPerSubject() SubOpt { |
| 2558 | return subOptFn(func(opts *subOpts) error { |
| 2559 | opts.cfg.DeliverPolicy = DeliverLastPerSubjectPolicy |
| 2560 | return nil |
| 2561 | }) |
| 2562 | } |
| 2563 | |
| 2564 | // DeliverNew configures a Consumer to receive messages |
| 2565 | // published after the subscription. |
no test coverage detected