D-Net

import java.util.concurrent.BlockingQueue;

import java.util.concurrent.Executor;

import java.util.concurrent.Executors;

import javax.annotation.Resource;

import javax.xml.ws.wsaddressing.W3CEndpointReference;

import com.googlecode.sarasvati.Arc;

import com.googlecode.sarasvati.NodeToken;

import eu.dnetlib.data.collector.plugins.datasets.DatasetsByJournalIterator;

import eu.dnetlib.data.collector.plugins.datasets.PangaeaJournalInfo;

import eu.dnetlib.enabling.resultset.IterableResultSetFactory;

import eu.dnetlib.enabling.resultset.client.ResultSetClientFactory;

import eu.dnetlib.enabling.resultset.client.utils.EPRUtils;

import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;

// TODO: Auto-generated Javadoc

/**

 * The Class CollectDatasetsByJournalJobNode.

 */

	public static PangaeaJournalInfo END_QUEUE = new PangaeaJournalInfo();

	private String datasourceId;

	private String outputEprParam;

	private String inputEprParam;

	private ResultSetClientFactory resultSetClientFactory;

	@Resource(name = "iterableResultSetFactory")

	private IterableResultSetFactory resultSetFactory;

	private Executor executor = Executors.newSingleThreadExecutor();

	/*

	/**

	 * Sets the datasource id.

	 *

	 */

	public void setDatasourceId(final String datasourceId) {

		this.datasourceId = datasourceId;

	}

	/**

	 */

	public void setOutputEprParam(final String outputEprParam) {

		this.outputEprParam = outputEprParam;

	}

	/**

	 */

	public void setInputEprParam(final String inputEprParam) {

		this.inputEprParam = inputEprParam;

	/**

	 * Sets the result set client factory.

	 *

	 */

	public void setResultSetClientFactory(final ResultSetClientFactory resultSetClientFactory) {

		this.resultSetClientFactory = resultSetClientFactory;