org.apache.tika.batch

Class StatusReporter

java.lang.Object

org.apache.tika.batch.StatusReporter

All Implemented Interfaces:

java.util.concurrent.Callable<IFileProcessorFutureResult>

public class StatusReporter
extends java.lang.Object
implements java.util.concurrent.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.

Field Summary

Fields

Modifier and Type	Field and Description
private ConsumersManager	consumersManager
private FileResourceCrawler	crawler
private boolean	isShuttingDown
private static org.slf4j.Logger	LOG
private long	sleepMillis
private long	staleThresholdMillis
private long	start

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
IFileProcessorFutureResult	call() Startup the reporter.
private int	getRoughCountConsumed()
int	getRoughCountExceptions() This returns a rough (unsynchronized) count of caught/handled exceptions.
private int	getStillAlive()
protected void	report(java.lang.String s) Override for different behavior.
private void	reportStale()
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

Field Detail

LOG

private static final org.slf4j.Logger LOG

consumersManager

private final ConsumersManager consumersManager

crawler

private final FileResourceCrawler crawler

start

private final long start

sleepMillis

private long sleepMillis

staleThresholdMillis

private long staleThresholdMillis

isShuttingDown

private volatile boolean isShuttingDown

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(java.lang.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 java.util.concurrent.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

reportStale

private void reportStale()

getRoughCountConsumed

private int getRoughCountConsumed()

getStillAlive

private int getStillAlive()

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 -