D-Net

package eu.dnetlib.data.collector.plugins;

import java.io.BufferedInputStream;

import eu.dnetlib.data.collector.rmi.CollectorServiceException;

import org.apache.commons.io.IOUtils;

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

public class HttpCollectorPlugin extends AbstractSplittedRecordPlugin {

	@Autowired

	private HttpConnector httpConnector;

	@Override

	protected BufferedInputStream getBufferedInputStream(final String baseUrl) throws CollectorServiceException {

		String res = httpConnector.getInputSource(baseUrl);

		return new BufferedInputStream(IOUtils.toInputStream(res));

	}

}