D-Net

import java.util.Queue;

import java.util.concurrent.*;

import com.google.common.collect.Lists;

import com.google.common.util.concurrent.*;

import eu.dnetlib.openaire.exporter.datasource.ApiException;

import eu.dnetlib.openaire.exporter.datasource.clients.utils.IndexDsInfo;

import eu.dnetlib.openaire.exporter.datasource.clients.utils.IndexRecordsInfo;

import org.apache.commons.logging.LogFactory;

import org.apache.http.HttpStatus;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.domain.Pageable;

import org.springframework.data.domain.Slice;

import org.springframework.stereotype.Component;

	private static final Log log = LogFactory.getLog(DatasourceDao.class);

	@Autowired

	private MongoLoggerClient mongoLoggerClient;

	@Autowired

	private ListeningExecutorService service;

		service = MoreExecutors.listeningDecorator(

						new ThreadFactoryBuilder().setNameFormat("datasource-info-retriever-%d").build()));

	}

				dsRepository.findByOfficialnameContainingOrEnglishnameContainingAllIgnoreCase(name, name, pageable);

		c.addCallback(getSearchCallback(outerLatch, errors, datasourceResponse));

		return datasourceResponse;

	}

		log.debug(String.format("search ds by country '%s'", country));

		//dsRepository.findByOrganizationsCountryIgnoreCase(country, pageable).addCallback(getSearchCallback(outerLatch, errors, datasourceResponse));

		return datasourceResponse;

	}

		log.debug(String.format("search ds by email '%s'", email));

		dsRepository.findByContactemailContainingAllIgnoreCase(email, pageable).addCallback(getSearchCallback(outerLatch, errors, datasourceResponse));

		return datasourceResponse;

	}

		getIndexDsInfo(dsId, outerLatch, errors, datasourceResponse);

		/*

		if (!errors.isEmpty()) {

										innerLatch.countDown();

									}

						});

						outerLatch.countDown();

					}