Function WithMessageProcessingReserveDuration

consumer.go:189–193

WithMessageProcessingReserveDuration sets the duration for which the message is reserved for handling result state.

(d time.Duration)

// WithMetrics sets metrics meter. Default is noop.Meter{}.
func WithMetrics(m metric.Meter) ConsumerOption {
	return func(c *consumerConfig) {
		c.Metrics = m
	}
}

// WithMessageProcessingReserveDuration sets the duration for which the message is reserved for handling result state.
func WithMessageProcessingReserveDuration(d time.Duration) ConsumerOption {
	return func(c *consumerConfig) {