Function WithInvalidMessageCallback

consumer.go:196–200

WithInvalidMessageCallback sets callback for invalid messages.

(fn InvalidMessageCallback)

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

// WithInvalidMessageCallback sets callback for invalid messages.
func WithInvalidMessageCallback(fn InvalidMessageCallback) ConsumerOption {
	return func(c *consumerConfig) {