func (s *Storage) Close() error {
	s.mtx.Lock()
	defer s.mtx.Unlock()

	for _, q := range s.queues {
		q.Stop()
	}

	return nil
}
func (s *Storage) Close() error {
	s.mtx.Lock()
	defer s.mtx.Unlock()

	for _, q := range s.queues {
		q.Stop()
	}

	return nil
}
func ( s * Storage ) Close ( ) error { s . mtx . Lock ( ) defer s . mtx . Unlock ( ) for _ , q := range s . queues { q . Stop ( ) } return nil }
// Close the background processing of the storage queues.
Close the background processing of the storage queues .