source: OAIHarvester/trunk/OAIHarvester/src/main/java/eu/clarin/cmdi/oai/harvester/impl/SimpleHarvester.java @ 1137

package eu.clarin.cmdi.oai.harvester.impl;

import java.net.URI;
import java.util.concurrent.TimeUnit;

import eu.clarin.cmdi.oai.harvester.HarvestHandler;
import eu.clarin.cmdi.oai.harvester.HarvestJob;
import eu.clarin.cmdi.oai.harvester.Harvester;
import eu.clarin.cmdi.oai.harvester.HarvesterException;

public final class SimpleHarvester extends AbstractHarvester {
    private HarvestWorker worker;
    private long nextId = 0;

    private SimpleHarvester() {
        this.worker = new HarvestWorker(this);
    }

    @Override
    public HarvestJob createJob(URI repositoryURI, HarvestHandler handler) {
        if (repositoryURI == null) {
            throw new IllegalArgumentException("repositoryURI == null");
        }
        long jobId;
        synchronized (this) {
            jobId = ++nextId;
        } // synchronized
        return new HarvestJobImpl(this, jobId, repositoryURI, handler);
    }

    public static Harvester newInstance() {
        return new SimpleHarvester();
    }

    @Override
    public void shutdown() {
    }

    @Override
    void doRunJob(HarvestJobImpl job) throws HarvesterException {
        if (job.getState() != HarvestJob.State.NEW) {
            throw new IllegalStateException("job is already in state: " +
                    job.getState());
        }

        job.setState(HarvestJob.State.RUNNING);

        while (job.isRunning()) {
            worker.process(job, 15);
            long delay = -1;
            while (job.isRunning() &&
                    ((delay = job.getDelay(TimeUnit.MILLISECONDS)) > 0)) {
                try {
                    System.err.println(job.getId() + ": (" +
                            job.getNetworkRequestCount() + ") waiting " +
                            delay + " ...");
                    Thread.sleep(delay);
                } catch (InterruptedException e) {
                }
                delay = job.getDelay(TimeUnit.MILLISECONDS);
            } // while (wait loop)
        } // while
    }

    @Override
    void doCancelJob(HarvestJobImpl job) throws HarvesterException {
        throw new HarvesterException("cancel() is not supported");
    }

    @Override
    protected HarvestJob doFindJob(String id) throws HarvesterException {
        throw new HarvesterException("findJob() is not supported"); 
    }

} // class SimpleHarvester