Package dk.netarkivet.harvester.scheduler

Class HarvestSchedulerMonitorServer

java.lang.Object

dk.netarkivet.harvester.distribute.HarvesterMessageHandler

dk.netarkivet.harvester.scheduler.HarvestSchedulerMonitorServer

All Implemented Interfaces:

ComponentLifeCycle, HarvesterMessageVisitor, javax.jms.MessageListener

public class HarvestSchedulerMonitorServer
extends HarvesterMessageHandler
implements javax.jms.MessageListener, ComponentLifeCycle

Submitted harvesting jobs are registered by listening for CrawlStatusMessages on the THE_SCHED queue and processes completed harvests.

Constructor Summary

Constructors

Constructor	Description
HarvestSchedulerMonitorServer(javax.inject.Provider<JMSConnection> jmsConnectionProvider, javax.inject.Provider<JobDAO> jobDAOProvider, javax.inject.Provider<HarvestDefinitionDAO> harvestDefinitionDAOProvider, javax.inject.Provider<Notifications> notificationsProvider)

Method Summary

Modifier and Type	Method	Description
void	shutdown()	Removes the HarvestSchedulerMonitorServer as listener to the JMS scheduler Channel.
void	start()	Implements functionality for starting an instances of this ComponentLifeCycle object.
void	visit(IndexReadyMessage msg)	This method should be overridden and implemented by a sub class if message handling is wanted.
void	visit(CrawlStatusMessage msg)	This method should be overridden and implemented by a sub class if message handling is wanted.

Methods inherited from class dk.netarkivet.harvester.distribute.HarvesterMessageHandler

onMessage, visit, visit, visit, visit, visit, visit, visit, visit

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.MessageListener

onMessage

Constructor Detail

HarvestSchedulerMonitorServer

public HarvestSchedulerMonitorServer(javax.inject.Provider<JMSConnection> jmsConnectionProvider,
                                     javax.inject.Provider<JobDAO> jobDAOProvider,
                                     javax.inject.Provider<HarvestDefinitionDAO> harvestDefinitionDAOProvider,
                                     javax.inject.Provider<Notifications> notificationsProvider)

Method Detail

start

public void start()

Description copied from interface: ComponentLifeCycle

Implements functionality for starting an instances of this ComponentLifeCycle object. This may be loading files, establish connections, initializing data, starting threads, etc.

Specified by:

start in interface ComponentLifeCycle

visit

public void visit(CrawlStatusMessage msg)

Description copied from class: HarvesterMessageHandler

This method should be overridden and implemented by a sub class if message handling is wanted.

Specified by:

visit in interface HarvesterMessageVisitor

Overrides:

visit in class HarvesterMessageHandler

Parameters:

msg - a given CrawlStatusMessage

See Also:

HarvesterMessageHandler.visit(dk.netarkivet.harvester.harvesting.distribute.CrawlStatusMessage)

shutdown

public void shutdown()

Removes the HarvestSchedulerMonitorServer as listener to the JMS scheduler Channel.

Specified by:

shutdown in interface ComponentLifeCycle

visit

public void visit(IndexReadyMessage msg)

Description copied from class: HarvesterMessageHandler

This method should be overridden and implemented by a sub class if message handling is wanted.

Specified by:

visit in interface HarvesterMessageVisitor

Overrides:

visit in class HarvesterMessageHandler

Parameters:

msg - a IndexReadyMessage