Function WithStopOnEmptyQueue

consumer.go:230–234

WithStopOnEmptyQueue sets whether the consumer should run until no messages can be consumed.

(finiteConsumption bool)

// WithLogger sets logger. Default is no logging.
func WithLogger(logger *slog.Logger) ConsumerOption {
	return func(c *consumerConfig) {
		c.Logger = logger
	}
}

// WithStopOnEmptyQueue sets whether the consumer should run until no messages can be consumed.
func WithStopOnEmptyQueue(finiteConsumption bool) ConsumerOption {
	return func(c *consumerConfig) {