Package org.apache.manifoldcf.crawler.system

Class DocumentCleanupThread

  • All Implemented Interfaces:
    java.lang.Runnable
    public class DocumentCleanupThread
extends java.lang.Thread
    This class represents a document cleanup thread. This thread's job is to pull document sets to be cleaned up off of a queue, and kill them. It finishes a cleanup set by getting rid of the corresponding rows in the job queue, and from carrydown, and from hopcount. There are very few decisions that this thread needs to make; essentially all the hard thought went into deciding what documents to queue in the first place. The only caveat is that the ingestion API may not be accepting delete requests at the time that this thread wants it to be able to accept them. In that case, it's acceptable for the thread to block until the ingestion service is functioning again. Transactions are not much needed for this class; it simply needs to not fail to remove the appropriate jobqueue table rows at the end of the delete.

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      protected static class  DocumentCleanupThread.OutputRemoveActivity
      The ingest logger class

      • Nested classes/interfaces inherited from class java.lang.Thread

        java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void run()  

      • Methods inherited from class java.lang.Thread

        activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • id

        protected final java.lang.String id
        Thread id

      • documentCleanupQueue

        protected final DocumentCleanupQueue documentCleanupQueue
        This is a reference to the static main document queue

      • processID

        protected final java.lang.String processID
        Process ID

    • Method Detail

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
        Overrides:
        run in class java.lang.Thread