org.deegree.ogcwebservices.csw.manager
Class AbstractHarvester

java.lang.Object
  java.util.TimerTask
      org.deegree.ogcwebservices.csw.manager.AbstractHarvester

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

CatalogueHarvester, CSWProfileHarvester, ServiceHarvester

public abstract class AbstractHarvester
extends TimerTask

Abstract super class of all CS-W harvesters. For each kind of source a specialized harvester shall be implemented. A concrete implementation of AbstractHarvester will be called within a timer loop.

Since:

2.0

Version:

$Revision: 7675 $, 1.0. $Revision: 7675 $, $Date: 2007-06-28 18:31:47 +0200 (Do, 28 Jun 2007) $

Author:

Andreas Poth, last edited by: $Author: apoth $

Nested Class Summary

protected class

AbstractHarvester.AbstractHarvestProcessor abstract super class for all harvest processores

Field Summary

protected List<URI>	inProgress
protected static NamespaceContext	nsc

Constructor Summary

AbstractHarvester()

Method Summary

void	addRequest(Harvest request) adds a request to the harvesting process
protected void	informResponseHandlers(URI source) informs all response handlers assigend to a source about successful harvesting of the source
protected void	informResponseHandlers(URI source, Throwable e) informs all response handlers assigend to a source about an exception that occurs when harvesting a source
boolean	isRunning() returns true if the harvesting process is running
void	removeRequest(Harvest request) removes a request from the harvesting request.
protected boolean	shallHarvest(URI source, HarvestRepository.ResourceType targetType) returns true if the passed source shall be harvested. this is true if a source has not been harvested before or the next harvesting timestamp has been reached and the source is of type
void	startHarvesting() starts the harvesting process
void	stopHarvesting() stops the harvesting process

Methods inherited from class java.util.TimerTask

cancel, run, scheduledExecutionTime

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inProgress

protected List<URI> inProgress

nsc

protected static NamespaceContext nsc

Constructor Detail

AbstractHarvester

public AbstractHarvester()

Method Detail

addRequest

public void addRequest(Harvest request)
                throws IOException,
                       DBPoolException,
                       SQLException

adds a request to the harvesting process

Parameters:

request -

Throws:

SQLException

DBPoolException

IOException

isRunning

public boolean isRunning()

returns true if the harvesting process is running

Returns:

true if the harvesting process is running

removeRequest

public void removeRequest(Harvest request)
                   throws IOException,
                          DBPoolException,
                          SQLException

removes a request from the harvesting request.

!! At the moment the OGC CSW does not know a mechanism/request to stop a cyclic harvesting job, so this method can not be called with a standard OGC OWS request !!

Parameters:

request -

Throws:

SQLException

DBPoolException

IOException

startHarvesting

public void startHarvesting()

starts the harvesting process

stopHarvesting

public void stopHarvesting()

stops the harvesting process

informResponseHandlers

protected void informResponseHandlers(URI source)
                               throws IOException,
                                      DBPoolException,
                                      SQLException,
                                      URISyntaxException

informs all response handlers assigend to a source about successful harvesting of the source

Parameters:

source -

Throws:

URISyntaxException

SQLException

DBPoolException

MalformedURLException

IOException

shallHarvest

protected boolean shallHarvest(URI source,
                               HarvestRepository.ResourceType targetType)
                        throws IOException,
                               DBPoolException,
                               SQLException

returns true if the passed source shall be harvested. this is true if a source has not been harvested before or the next harvesting timestamp has been reached and the source is of type

Parameters:

source -

Returns:

true if the passed source shall be harvested

Throws:

DBPoolException

SQLException

IOException

See Also:

service

informResponseHandlers

protected void informResponseHandlers(URI source,
                                      Throwable e)
                               throws IOException,
                                      DBPoolException,
                                      SQLException,
                                      URISyntaxException

informs all response handlers assigend to a source about an exception that occurs when harvesting a source

Parameters:

source -

e -

Throws:

URISyntaxException

SQLException

DBPoolException

IOException