Class InProcessCache

Method Details

• registerCallbackWhenCacheEmpty

  public void registerCallbackWhenCacheEmpty(EventSubscriber aController)

• registerCallbackWhenCacheEmpty

  public void registerCallbackWhenCacheEmpty(EventSubscriber aController, int notification)

• destroy

  public void destroy()

• isInputCASPendingReply

  public boolean isInputCASPendingReply(String anInputCASReferenceId) throws 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:

  Exception

• producedCASesStillInPlay

  public boolean producedCASesStillInPlay(String anInputCASReferenceId, String aSubordinateCASReferenceId) throws Exception

  Throws:

  Exception

• releaseCASesProducedFromInputCAS

  public void releaseCASesProducedFromInputCAS(String anInputCASReferenceId)

• releaseAllCASes

  public void releaseAllCASes()

• setName

  public void setName(String aName)

  Specified by:

  setName in interface InProcessCacheMBean

• getName

  public String getName()

  Specified by:

  getName in interface InProcessCacheMBean

• cancelTimers

  public void cancelTimers()

• isEmpty

  public boolean isEmpty()

• reset

  public void reset()

  Specified by:

  reset in interface InProcessCacheMBean

• getSize

  public int getSize()

  Specified by:

  getSize in interface InProcessCacheMBean

• setSize

  public void setSize(int i)

  Specified by:

  setSize in interface InProcessCacheMBean

• dumpContents

  public void dumpContents(String aControllerName)

• remove

  public void remove(String aCasReferenceId)

• removeCas

  public void removeCas(String aCasReferenceId)

• getCacheEntriesForEndpoint

  public InProcessCache.CacheEntry[] getCacheEntriesForEndpoint(String anEndpointName)

• saveSerializedCAS

  public void saveSerializedCAS(String aCasReferenceId, String anXCAS)

• getSerializedCAS

  public String getSerializedCAS(String aCasReferenceId)

• setCasProducer

  public void setCasProducer(String aCasReferenceId, String aCasProducerKey)

• getCasProducer

  public String getCasProducer(String aCasReferenceId)

• getCasByReference

  public org.apache.uima.cas.CAS getCasByReference(String aCasReferenceId)

• getMessageAccessorByReference

  public MessageContext getMessageAccessorByReference(String aCasReferenceId)

• getOutOfTypeSystemData

  public org.apache.uima.cas.impl.OutOfTypeSystemData getOutOfTypeSystemData(String aCasReferenceId)

• addEndpoint

  public void addEndpoint(Endpoint anEndpoint, String aCasReferenceId)

• getEndpoint

  public Endpoint getEndpoint(String anEndpointName, String aCasReferenceId)

• removeEndpoint

  public void removeEndpoint(String anEndpointName, String aCasReferenceId)

• getStartTime

  public long getStartTime(String aCasReferenceId)

• entryExists

  public boolean entryExists(String aCasReferenceId)

• register

  public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.OutOfTypeSystemData otsd) throws AsynchAEException

  Throws:

  AsynchAEException

• register

  public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.XmiSerializationSharedData sharedData) throws AsynchAEException

  Throws:

  AsynchAEException

• register

  public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.OutOfTypeSystemData otsd, String aCasReferenceId) throws AsynchAEException

  Throws:

  AsynchAEException

• register

  public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.XmiSerializationSharedData sharedData, String aCasReferenceId) throws AsynchAEException

  Throws:

  AsynchAEException

• register

  public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.XmiSerializationSharedData sharedData, String aCasReferenceId, org.apache.uima.cas.Marker marker, boolean acceptsDeltaCas) throws AsynchAEException

  Throws:

  AsynchAEException

• hasNoSubordinates

  public boolean hasNoSubordinates(String aCasReferenceId)

• getTopAncestorEndpoint

  public Endpoint getTopAncestorEndpoint(InProcessCache.CacheEntry anEntry) throws Exception

  Throws:

  Exception

• getCacheEntryForCAS

  public InProcessCache.CacheEntry getCacheEntryForCAS(String aCasReferenceId) throws AsynchAEException

  Throws:

  AsynchAEException