Function WithMaxParallelMessages

consumer.go:175–179

WithMaxParallelMessages sets how many jobs can single consumer process simultaneously.

(n int)

func WithAckTimeout(d time.Duration) ConsumerOption {
	return func(c *consumerConfig) {
		c.AckTimeout = d
	}
}

// WithMaxParallelMessages sets how many jobs can single consumer process
// simultaneously.
func WithMaxParallelMessages(n int) ConsumerOption {
	return func(c *consumerConfig) {