Class InProcessCache

    • Field Detail

    • Constructor Detail

      • InProcessCache

        public InProcessCache()
    • Method Detail

      • registerCallbackWhenCacheEmpty

        public void registerCallbackWhenCacheEmpty​(EventSubscriber aController)
      • registerCallbackWhenCacheEmpty

        public void registerCallbackWhenCacheEmpty​(EventSubscriber aController,
                                                   int notification)
      • destroy

        public void destroy()
      • isInputCASPendingReply

        public boolean isInputCASPendingReply​(java.lang.String anInputCASReferenceId)
                                       throws java.lang.Exception
        Checks if a given input CAS is in pending state. CAS is in pending state if it has been fully processed, *but* its subordinate CASes are still in play. Input CAS is only returned back to the client if all if its subordinate CASes are fully processed.
        Parameters:
        anInputCASReferenceId -
        Returns:
        Throws:
        java.lang.Exception
      • producedCASesStillInPlay

        public boolean producedCASesStillInPlay​(java.lang.String anInputCASReferenceId,
                                                java.lang.String aSubordinateCASReferenceId)
                                         throws java.lang.Exception
        Throws:
        java.lang.Exception
      • releaseCASesProducedFromInputCAS

        public void releaseCASesProducedFromInputCAS​(java.lang.String anInputCASReferenceId)
      • releaseAllCASes

        public void releaseAllCASes()
      • cancelTimers

        public void cancelTimers()
      • isEmpty

        public boolean isEmpty()
      • dumpContents

        public void dumpContents​(java.lang.String aControllerName)
      • remove

        public void remove​(java.lang.String aCasReferenceId)
      • removeCas

        public void removeCas​(java.lang.String aCasReferenceId)
      • getCacheEntriesForEndpoint

        public InProcessCache.CacheEntry[] getCacheEntriesForEndpoint​(java.lang.String anEndpointName)
      • saveSerializedCAS

        public void saveSerializedCAS​(java.lang.String aCasReferenceId,
                                      java.lang.String anXCAS)
      • getSerializedCAS

        public java.lang.String getSerializedCAS​(java.lang.String aCasReferenceId)
      • setCasProducer

        public void setCasProducer​(java.lang.String aCasReferenceId,
                                   java.lang.String aCasProducerKey)
      • getCasProducer

        public java.lang.String getCasProducer​(java.lang.String aCasReferenceId)
      • getCasByReference

        public org.apache.uima.cas.CAS getCasByReference​(java.lang.String aCasReferenceId)
      • getMessageAccessorByReference

        public MessageContext getMessageAccessorByReference​(java.lang.String aCasReferenceId)
      • getOutOfTypeSystemData

        public org.apache.uima.cas.impl.OutOfTypeSystemData getOutOfTypeSystemData​(java.lang.String aCasReferenceId)
      • addEndpoint

        public void addEndpoint​(Endpoint anEndpoint,
                                java.lang.String aCasReferenceId)
      • getEndpoint

        public Endpoint getEndpoint​(java.lang.String anEndpointName,
                                    java.lang.String aCasReferenceId)
      • removeEndpoint

        public void removeEndpoint​(java.lang.String anEndpointName,
                                   java.lang.String aCasReferenceId)
      • getStartTime

        public long getStartTime​(java.lang.String aCasReferenceId)
      • entryExists

        public boolean entryExists​(java.lang.String aCasReferenceId)
      • hasNoSubordinates

        public boolean hasNoSubordinates​(java.lang.String aCasReferenceId)