Function WithScheduleTarget

jetstream/jetstream_options.go:762–770

WithScheduleTarget sets the subject where scheduled messages will be delivered. This option is required for scheduled messages. Requires [StreamConfig.AllowMsgSchedules] to be enabled.

(subject string)

// This option is required for scheduled messages.
// Requires [StreamConfig.AllowMsgSchedules] to be enabled.
func WithScheduleTarget(subject string) PublishOpt {
	return func(opts *pubOpts) error {
		if subject == "" {
			return fmt.Errorf("%w: schedule target subject cannot be empty", ErrInvalidOption)
		}
		opts.scheduleTarget = subject
		return nil
	}
}

// WithScheduleSource instructs the scheduler to read the latest message
// from the given subject and republish it on schedule. Used for data