Function WithPublishAsyncErrHandler

jetstream/jetstream_options.go:41–46

WithPublishAsyncErrHandler sets error handler for async message publish.

(cb MsgErrHandler)

// WithPublishAsyncErrHandler sets error handler for async message publish.
func WithPublishAsyncErrHandler(cb MsgErrHandler) JetStreamOpt {
	return func(opts *JetStreamOptions) error {
		opts.publisherOpts.aecb = cb
		return nil
	}
}

// WithPublishAsyncMaxPending sets the maximum outstanding async publishes that
// can be inflight at one time.