Class ProcessingContainer

    • Constructor Detail

      • ProcessingContainer

        public ProcessingContainer()
    • Method Detail

      • processCas

        public abstract boolean processCas​(java.lang.Object[] aCas)
      • releaseCasProcessor

        public abstract void releaseCasProcessor​(CasProcessor aCasProcessor)
      • getName

        public abstract java.lang.String getName()
      • abortCPMOnError

        public abstract boolean abortCPMOnError()
      • incrementCasProcessorErrors

        public abstract void incrementCasProcessorErrors​(java.lang.Throwable aThrowable)
                                                  throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getProcessed

        public abstract long getProcessed()
      • setProcessed

        public abstract void setProcessed​(long aProcessedCount)
      • getBytesIn

        public abstract long getBytesIn()
      • addBytesIn

        public abstract void addBytesIn​(long aBytesIn)
      • getBytesOut

        public abstract long getBytesOut()
      • addBytesOut

        public abstract void addBytesOut​(long aBytesOut)
      • incrementRestartCount

        public abstract void incrementRestartCount​(int aCount)
      • getRestartCount

        public abstract int getRestartCount()
      • incrementRetryCount

        public abstract void incrementRetryCount​(int aCount)
      • getRetryCount

        public abstract int getRetryCount()
      • incrementAbortCount

        public abstract void incrementAbortCount​(int aCount)
      • getAbortCount

        public abstract int getAbortCount()
      • incrementFilteredCount

        public abstract void incrementFilteredCount​(int aCount)
      • getFilteredCount

        public abstract int getFilteredCount()
      • getRemaining

        public abstract long getRemaining()
      • setRemaining

        public abstract void setRemaining​(long aRemainingCount)
      • setLastProcessedEntityId

        public abstract void setLastProcessedEntityId​(java.lang.String entityId)
      • getLastProcessedEntityId

        public abstract java.lang.String getLastProcessedEntityId()
      • incrementTotalTime

        public abstract void incrementTotalTime​(long aTime)
      • getTotalTime

        public abstract long getTotalTime()
      • logAbortedCases

        public abstract void logAbortedCases​(java.lang.Object[] abortedCasList)
      • setLastCas

        public abstract void setLastCas​(java.lang.Object aCasObject)
      • getLastCas

        public abstract java.lang.Object getLastCas()
      • setCasProcessorDeployer

        public abstract void setCasProcessorDeployer​(CasProcessorDeployer aDeployer)
      • getAllStats

        public abstract java.util.HashMap getAllStats()
      • addStat

        public abstract void addStat​(java.lang.String aStatName,
                                     java.lang.Object aStat)
      • incrementStat

        public abstract void incrementStat​(java.lang.String aStatName,
                                           java.lang.Integer aStat)
      • getStat

        public abstract java.lang.Object getStat​(java.lang.String aStatName)
      • resetRestartCount

        public abstract void resetRestartCount()
      • pause

        public abstract void pause()
      • resume

        public abstract void resume()
      • isPaused

        public abstract boolean isPaused()
      • setSingleFencedService

        public abstract void setSingleFencedService​(boolean aSingleFencedInstance)
      • isSingleFencedService

        public abstract boolean isSingleFencedService()