Package com.jalios.jcms.fileprocessor.processingmanagement

Class ProcessingThread

  • All Implemented Interfaces:
    java.lang.Runnable
    public class ProcessingThread
extends java.lang.Thread
    This class is a Thread of processing. ProcessingData are submitted to this thread with a producer/consumer mecanism. This thread may be started and stopped through FileProcessorManager.

    • Nested Class Summary

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

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

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static int MAX_THROWABLE
      Maximum number of throwable allowed per component (processor/parser) before considering it should be removed from repository configuration
      static java.lang.String REVISION  

      • Fields inherited from class java.lang.Thread

        MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      ProcessingData getLastProcessingData()
      Retrieve the ProcessingData instance that processed during last loop of this thread.
      boolean isProcessingAlive()
      Tell if the processing of files is alive (which is expected at all time after JCMS startup, even if FileProcessor is disabled, otherwise a complete restart is required).
      boolean isProcessingRunning()
      Tell if the processing of files is running (Otherwise, it is stopped, or waiting).
      static void resetThrowableCounter()
      Reset all throwable counters.
      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

      • MAX_THROWABLE

        public static final int MAX_THROWABLE
        Maximum number of throwable allowed per component (processor/parser) before considering it should be removed from repository configuration
        See Also:
        Constant Field Values

    • Method Detail

      • run

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

      • isProcessingAlive

        public boolean isProcessingAlive()
        Tell if the processing of files is alive (which is expected at all time after JCMS startup, even if FileProcessor is disabled, otherwise a complete restart is required).
        Returns:
        true if the processing is currently not stopped

      • isProcessingRunning

        public boolean isProcessingRunning()
        Tell if the processing of files is running (Otherwise, it is stopped, or waiting).
        Returns:
        true if the processing is currently running

      • getLastProcessingData

        public ProcessingData getLastProcessingData()
        Retrieve the ProcessingData instance that processed during last loop of this thread.
        Returns:
        a ProcessingData instance or null if no processing has yet occured.

      • resetThrowableCounter

        public static void resetThrowableCounter()
        Reset all throwable counters.

        Used during unit test in which processors voluntarly triggers failures but do not want to be excluded.