package eu.dnetlib.data.common;

import javax.annotation.Resource;
import javax.xml.ws.wsaddressing.W3CEndpointReference;

import org.quartz.Job;

import eu.dnetlib.data.information.DataSinkResolver;
import eu.dnetlib.data.information.DataSinkSourceException;

public abstract class AbstractHarvestJob implements Job {
	/**
	 * 
	 */
	@Resource(name = "dataSinkResolver")
	private DataSinkResolver dataSinkResolver;

	protected void fillMDStore(final String dataSink, final W3CEndpointReference rsEpr) {
		try {
			dataSinkResolver.resolve(dataSink).store(rsEpr);
		} catch (DataSinkSourceException e) {
			throw new IllegalArgumentException(e);
		}
	}

	public DataSinkResolver getDataSinkResolver() {
		return dataSinkResolver;
	}

	public void setDataSinkResolver(DataSinkResolver dataSinkResolver) {
		this.dataSinkResolver = dataSinkResolver;
	}
}