dk.netarkivet.harvester.scheduler
Class JobDispatcher
java.lang.Object
dk.netarkivet.harvester.scheduler.JobDispatcher
public class JobDispatcher
- extends java.lang.Object
This class handles dispatching of Harvest jobs to the Harvesters.
Method Summary |
void |
doOneCrawl(Job job,
java.lang.String origHarvestName,
java.lang.String origHarvestDesc,
java.lang.String origHarvestSchedule,
HarvestChannel channel,
java.lang.String origHarvestAudience,
java.util.List<MetadataEntry> metadata)
Submit an doOneCrawl request to a HarvestControllerServer. |
protected void |
submitNextNewJob(HarvestChannel channel)
Submit the next new job (the one with the lowest ID) with the given
priority, and updates the internal counter as needed. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JobDispatcher
public JobDispatcher(JMSConnection jmsConnection,
HarvestDefinitionDAO hDao,
JobDAO jobDao)
- Parameters:
jmsConnection
- The JMS connection to use.hDao
- The HarvestDefinitionDAO to use.
submitNextNewJob
protected void submitNextNewJob(HarvestChannel channel)
- Submit the next new job (the one with the lowest ID) with the given
priority, and updates the internal counter as needed. If no jobs are
ready for the given priority, nothing is done
- Parameters:
channel
- the Channel to use for the job.
doOneCrawl
public void doOneCrawl(Job job,
java.lang.String origHarvestName,
java.lang.String origHarvestDesc,
java.lang.String origHarvestSchedule,
HarvestChannel channel,
java.lang.String origHarvestAudience,
java.util.List<MetadataEntry> metadata)
throws ArgumentNotValid,
IOFailure
- Submit an doOneCrawl request to a HarvestControllerServer.
- Parameters:
job
- the specific job to sendorigHarvestName
- the harvest definition's nameorigHarvestDesc
- the harvest definition's descriptionorigHarvestSchedule
- the harvest definition schedule namechannel
- the channel to which the job should be sentmetadata
- pre-harvest metadata to store in arcfile.origHarvestAudience
- the audience for the data generated by harvest definitions.
- Throws:
ArgumentNotValid
- one of the parameters are null
IOFailure
- if unable to send the doOneCrawl request to a
harvestControllerServer