D-Net

    <orderEntry type="inheritedJdk" />

    <orderEntry type="sourceFolder" forTests="false" />

    <orderEntry type="library" name="Maven: eu.dnetlib:dnet-pace-core:2.5.1" level="project" />

    <orderEntry type="library" name="Maven: eu.dnetlib:cnr-rmi-api:2.6.2-SNAPSHOT" level="project" />

    <orderEntry type="library" name="Maven: org.apache.cxf:cxf-core:3.1.5" level="project" />

    <orderEntry type="library" name="Maven: org.apache.ws.xmlschema:xmlschema-core:2.2.1" level="project" />

    <orderEntry type="module" module-name="dnet-pace-core" />

    <orderEntry type="library" name="Maven: edu.cmu:secondstring:1.0.0" level="project" />

    <orderEntry type="library" name="Maven: commons-collections:commons-collections:3.2.2" level="project" />

    <orderEntry type="library" name="Maven: com.googlecode.protobuf-java-format:protobuf-java-format:1.2" level="project" />

    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpclient:4.5.3" level="project" />

    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpcore:4.4.6" level="project" />

    <orderEntry type="library" name="Maven: org.apache.httpcomponents:httpmime:4.5.3" level="project" />

    <orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper:3.4.10" level="project" />

    <orderEntry type="library" name="Maven: org.codehaus.woodstox:stax2-api:3.1.4" level="project" />

    <orderEntry type="library" name="Maven: org.codehaus.woodstox:woodstox-core-asl:4.4.1" level="project" />

    <orderEntry type="library" name="Maven: org.slf4j:jcl-over-slf4j:1.7.24" level="project" />

    <orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.24" level="project" />

    <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-web:1.5.2.RELEASE" level="project" />

package eu.dnetlib.openaire.exporter.datasource.clients;

import java.io.IOException;

import java.util.Map;

import java.util.Queue;

import java.util.concurrent.*;

import com.google.common.collect.Iterables;

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

import eu.dnetlib.OpenaireExporterConfig;

import eu.dnetlib.miscutils.functional.hash.Hashing;

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

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

import org.apache.commons.lang3.exception.ExceptionUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.apache.solr.client.solrj.response.QueryResponse;

import org.apache.solr.common.SolrDocument;

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

import org.springframework.http.HttpStatus;

import org.springframework.stereotype.Component;

	private ListeningExecutorService executor;

	@PostConstruct

	public void init() {

	public IndexRecordsInfo getIndexInfo(final String dsId, final IndexDsInfo info, final Queue<Throwable> errors) throws ApiException {

		try {

			final String collectedFrom = StringUtils.substringBefore(dsId, SEPARATOR) + SEPARATOR + Hashing.md5(StringUtils.substringAfter(dsId, SEPARATOR));

			final CountDownLatch latch = new CountDownLatch(2);

			final IndexRecordsInfo indexRecordInfo = new IndexRecordsInfo();

			Futures.addCallback(

						new FutureCallback<IndexRecordsInfo>() {

							@Override

							public void onSuccess(final IndexRecordsInfo info) {

	private Long setFunded(

			final String collectedFrom,

		log.debug(String.format("query: %s", query));

		try {

		} catch (Throwable e) {

			throw new ApiException(HttpStatus.INTERNAL_SERVER_ERROR.value(), "Error querying information system", e);

		}

	}

			final String collectedFrom,

		try {

			log.debug(String.format("query: %s", query));

			final SolrDocument doc = Iterables.getFirst(rsp.getResults(), new SolrDocument());

			if (log.isDebugEnabled()) {

				log.debug(String.format("got document %s", doc.toString()));

			}

			return new IndexRecordsInfo()

					.setTotal(rsp.getResults().getNumFound());

		} catch (Throwable e) {

			throw new ApiException(HttpStatus.INTERNAL_SERVER_ERROR.value(), "Error querying information system", e);

		}

	}

		}

	}

	}

		if (!indexClientMap.containsKey(info.getColl())) {

		}

		return indexClientMap.get(info.getColl());

	}

import org.apache.commons.logging.LogFactory;

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

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cache.annotation.EnableCaching;

import org.springframework.context.annotation.EnableAspectJAutoProxy;

import org.springframework.web.bind.annotation.RequestMapping;

@RestController

@SpringBootApplication

@EnableAspectJAutoProxy

public class DNetOpenaireExporterApplication {

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

		<persistence strategy="localTempSwap" />

	</cache>

</ehcache>

	<logger name="eu.dnetlib" level="INFO" additivity="false">

		<appender-ref ref="CONSOLE" />

	</logger>

		<appender-ref ref="CONSOLE" />

	</logger>

</configuration>

					<groupId>eu.dnetlib</groupId>

					<artifactId>dnet-hadoop-commons</artifactId>

				</exclusion>

			</exclusions>

		</dependency>

		<dependency>

	<properties>

		<java.version>1.8</java.version>

		<mongodb.driver.version>3.4.2</mongodb.driver.version>

		<springfox-version>2.7.0</springfox-version>

		<prometheus.version>0.0.25</prometheus.version>