Function hasReachedMaxRetryAttempt

cmd/workers.go:173–178

(cfg *config.Configuration, retryCount int)

}

func hasReachedMaxRetryAttempt(cfg *config.Configuration, retryCount int) bool {
	if cfg == nil || cfg.Queue.MaxRetryAttempts <= 0 {
		return false
	}
	return retryCount >= cfg.Queue.MaxRetryAttempts
}

func shouldRejectLockContentionImmediately(cfg *config.Configuration, err error) bool {
	if cfg == nil || !cfg.Queue.RejectLockContentionImmediately {