public class HarvestMonitor extends HarvesterMessageHandler implements javax.jms.MessageListener, CleanupIF
CrawlProgressMessage
s on the proper JMS channel, and stores information to be presented in the
monitoring console.Modifier and Type | Field and Description |
---|---|
static ChannelID |
HARVEST_MONITOR_CHANNEL_ID
The JMS channel on which to listen for
CrawlProgressMessage s. |
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Close down the HarvestMonitor singleton.
|
static int |
getAutoRefreshDelay()
Returns the delay in seconds after which a harvest monitor webpage should refresh itself.
|
static String |
getChartFilePath(long jobId)
Returns the path of the chart image file, relative to the webapp directory.
|
static InMemoryFrontierReport |
getFrontierExhaustedQueues(long jobId)
Retrieves the latest frontier extract report stored for the given job ID, that contains only exhausted queues.
|
static InMemoryFrontierReport |
getFrontierReport(long jobId)
Retrieves the latest frontier report stored for the given job ID.
|
static InMemoryFrontierReport |
getFrontierRetiredQueues(long jobId)
Retrieves the latest frontier extract report stored for the given job ID, that contains only retired queues.
|
static HarvestMonitor |
getInstance() |
static StartedJobInfo |
getMostRecentRunningJobInfo(long jobId)
Returns the most recent running job info record available for the given job ID.
|
static StartedJobInfo[] |
getMostRecentRunningJobInfos(long jobId)
Returns a configurable number of the most recent running job info records available for the given job ID.
|
Set |
getRunningJobs() |
void |
visit(CrawlProgressMessage msg)
This method should be overridden and implemented by a sub class if message handling is wanted.
|
void |
visit(FrontierReportMessage msg)
This method should be overridden and implemented by a sub class if message handling is wanted.
|
void |
visit(JobEndedMessage msg)
Cleans up the database on transitions to status DONE and FAILED.
|
onMessage, visit, visit, visit, visit, visit, visit, visit
public static final ChannelID HARVEST_MONITOR_CHANNEL_ID
CrawlProgressMessage
s.public void cleanup()
cleanup
in interface CleanupIF
CleanupIF.cleanup()
public static HarvestMonitor getInstance()
public void visit(CrawlProgressMessage msg)
HarvesterMessageHandler
visit
in interface HarvesterMessageVisitor
visit
in class HarvesterMessageHandler
msg
- a CrawlProgressMessage
public void visit(JobEndedMessage msg)
visit
in interface HarvesterMessageVisitor
visit
in class HarvesterMessageHandler
msg
- a JobEndedMessage
public static final int getAutoRefreshDelay()
HarvesterSettings.HARVEST_MONITOR_REFRESH_INTERVAL
property.public static StartedJobInfo[] getMostRecentRunningJobInfos(long jobId)
jobId
- HarvesterSettings.HARVEST_MONITOR_DISPLAYED_HISTORY_SIZE
public static StartedJobInfo getMostRecentRunningJobInfo(long jobId)
jobId
- public void visit(FrontierReportMessage msg)
HarvesterMessageHandler
visit
in interface HarvesterMessageVisitor
visit
in class HarvesterMessageHandler
msg
- a FrontierReportMessage
public static InMemoryFrontierReport getFrontierReport(long jobId)
jobId
- the job idpublic static InMemoryFrontierReport getFrontierRetiredQueues(long jobId)
jobId
- the job idpublic static InMemoryFrontierReport getFrontierExhaustedQueues(long jobId)
jobId
- the job idpublic static String getChartFilePath(long jobId)
jobId
- the job idpublic Set getRunningJobs()
Copyright © 2005–2016 The Royal Danish Library, the Danish State and University Library, the National Library of France and the Austrian National Library.. All rights reserved.