PublishAsyncErrHandler sets the error handler for async publishes in JetStream.
(cb MsgErrHandler)
| 975 | |
| 976 | // PublishAsyncErrHandler sets the error handler for async publishes in JetStream. |
| 977 | func PublishAsyncErrHandler(cb MsgErrHandler) JSOpt { |
| 978 | return jsOptFn(func(js *jsOpts) error { |
| 979 | js.aecb = cb |
| 980 | return nil |
| 981 | }) |
| 982 | } |
| 983 | |
| 984 | // PublishAsyncMaxPending sets the maximum outstanding async publishes that can be inflight at one time. |
| 985 | func PublishAsyncMaxPending(max int) JSOpt { |