func GetRetryInfoFromQueue() ([]RetryInfo, error) {
	p, err := GetPath(SectionRetry, "", "")
	if err != nil {
		return []RetryInfo{}, err
	}

	// Check all files in the directory
	files, err := afero.ReadDir(fs, p)
	if err != nil {
		return []RetryInfo{}, err
	}

	var results []RetryInfo
	for _, fileInfo := range files {
		// Not a dir, so not a message
		if !fileInfo.IsDir() {
			continue
		}

		// Collect message retry info from message
		mri, err := GetRetryInfo(SectionRetry, fileInfo.Name())
		if err != nil {
			continue
		}

		results = append(results, *mri)
	}

	return results, nil
}
// GetRetryInfoFromQueue retrieves a list of retry infos as found in the retry queue
GetRetryInfoFromQueue retrieves a list of retry infos as found in the retry queue
// GetRetryInfoFromQueue retrieves a list of retry infos as found in the retry queue
func GetRetryInfoFromQueue() ([]RetryInfo, error) {
	p, err := GetPath(SectionRetry, "", "")
	if err != nil {
		return []RetryInfo{}, err
	}
	files, err := afero.ReadDir(fs, p)
	if err != nil {
		return []RetryInfo{}, err
	}
	var results []RetryInfo
	for _, fileInfo := range files {
		if !fileInfo.IsDir() {
			continue
		}
		mri, err := GetRetryInfo(SectionRetry, fileInfo.Name())
		if err != nil {
			continue
		}
		results = append(results, *mri)
	}
	return results, nil
}
func GetRetryInfoFromQueue ( ) ( [ ] RetryInfo , error ) { p , err := GetPath ( SectionRetry , " " , " " ) if err != nil { return [ ] RetryInfo { } , err } files , err := afero . ReadDir ( fs , p ) if err != nil { return [ ] RetryInfo { } , err } var results [ ] RetryInfo for _ , fileInfo := range files { if ! fileInfo . IsDir ( ) { continue } mri , err := GetRetryInfo ( SectionRetry , fileInfo . Name ( ) ) if err != nil { continue } results = append ( results , * mri ) } return results , nil }
GetRetryInfoFromQueue retrieves a list of retry infos as found in the retry queue
GetRetryInfoFromQueue retrieves a list of retry infos as found in the retry queue
// Check all files in the directory // Not a dir, so not a message // Collect message retry info from message