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 Details

    • 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 Details

    • 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 -