Package org.apache.tika.batch

Class StatusReporter

java.lang.Object

org.apache.tika.batch.StatusReporter

All Implemented Interfaces:

Callable<IFileProcessorFutureResult>

public class StatusReporter
extends Object
implements Callable<IFileProcessorFutureResult>

Basic class to use for reporting status from both the crawler and the consumers. This wakes up roughly every sleepMillis and log.info's a status report.

Constructor Summary

Constructors

Constructor	Description
StatusReporter(FileResourceCrawler crawler, ConsumersManager consumersManager)	Initialize with the crawler and consumers

Method Summary

Modifier and Type	Method	Description
IFileProcessorFutureResult	call()	Startup the reporter.
int	getRoughCountExceptions()	This returns a rough (unsynchronized) count of caught/handled exceptions.
protected void	report(String s)	Override for different behavior.
void	setIsShuttingDown(boolean isShuttingDown)	Set whether the main process is in the process of shutting down.
void	setSleepMillis(long sleepMillis)	Set the amount of time to sleep between reports.
void	setStaleThresholdMillis(long staleThresholdMillis)	Set the amount of time in milliseconds to use as the threshold for determining a stale parse.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatusReporter

public StatusReporter(FileResourceCrawler crawler,
                      ConsumersManager consumersManager)

Initialize with the crawler and consumers

Parameters:

crawler - crawler to ping at intervals

consumersManager - consumers to ping at intervals

Method Detail

report

protected void report(String s)

Override for different behavior.

This reports the string at the info level to this class' logger.

Parameters:

s - string to report

call

public IFileProcessorFutureResult call()

Startup the reporter.

Specified by:

call in interface Callable<IFileProcessorFutureResult>

setSleepMillis

public void setSleepMillis(long sleepMillis)

Set the amount of time to sleep between reports.

Parameters:

sleepMillis - length to sleep btwn reports in milliseconds

setStaleThresholdMillis

public void setStaleThresholdMillis(long staleThresholdMillis)

Set the amount of time in milliseconds to use as the threshold for determining a stale parse.

Parameters:

staleThresholdMillis - threshold for determining whether or not to report a stale

getRoughCountExceptions

public int getRoughCountExceptions()

This returns a rough (unsynchronized) count of caught/handled exceptions.

Returns:

rough count of exceptions

setIsShuttingDown

public void setIsShuttingDown(boolean isShuttingDown)

Set whether the main process is in the process of shutting down.

Parameters:

isShuttingDown -