Function WithLockDuration

consumer.go:151–155

WithLockDuration sets the maximal duration for how long the message remains locked for other consumers.

(d time.Duration)

	sem       *semaphore.Weighted
}

// ConsumerOption applies option to consumerConfig.
type ConsumerOption func(c *consumerConfig)

// WithLockDuration sets the maximal duration for how long the message remains
// locked for other consumers.
func WithLockDuration(d time.Duration) ConsumerOption {
	return func(c *consumerConfig) {