Package org.apache.uima.aae
Class InProcessCache
java.lang.Object
org.apache.uima.aae.InProcessCache
- All Implemented Interfaces:
Serializable
,InProcessCacheMBean
- See Also:
-
Nested Class Summary
Nested Classes -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
addEndpoint
(Endpoint anEndpoint, String aCasReferenceId) void
void
destroy()
void
dumpContents
(String aControllerName) boolean
entryExists
(String aCasReferenceId) getCacheEntriesForEndpoint
(String anEndpointName) getCacheEntryForCAS
(String aCasReferenceId) org.apache.uima.cas.CAS
getCasByReference
(String aCasReferenceId) getCasProducer
(String aCasReferenceId) getEndpoint
(String anEndpointName, String aCasReferenceId) getMessageAccessorByReference
(String aCasReferenceId) getName()
org.apache.uima.cas.impl.OutOfTypeSystemData
getOutOfTypeSystemData
(String aCasReferenceId) getSerializedCAS
(String aCasReferenceId) int
getSize()
long
getStartTime
(String aCasReferenceId) boolean
hasNoSubordinates
(String aCasReferenceId) boolean
isEmpty()
boolean
isInputCASPendingReply
(String anInputCASReferenceId) Checks if a given input CAS is in pending state.boolean
producedCASesStillInPlay
(String anInputCASReferenceId, String aSubordinateCASReferenceId) register
(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.OutOfTypeSystemData otsd) register
(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.OutOfTypeSystemData otsd, String aCasReferenceId) register
(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.XmiSerializationSharedData sharedData) register
(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.XmiSerializationSharedData sharedData, String aCasReferenceId) 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) void
registerCallbackWhenCacheEmpty
(EventSubscriber aController) void
registerCallbackWhenCacheEmpty
(EventSubscriber aController, int notification) void
void
releaseCASesProducedFromInputCAS
(String anInputCASReferenceId) void
void
void
removeEndpoint
(String anEndpointName, String aCasReferenceId) void
reset()
void
saveSerializedCAS
(String aCasReferenceId, String anXCAS) void
setCasProducer
(String aCasReferenceId, String aCasProducerKey) void
void
setSize
(int i)
-
Field Details
-
NotifyWhenRegistering
public static final int NotifyWhenRegistering- See Also:
-
-
Constructor Details
-
InProcessCache
public InProcessCache()
-
-
Method Details
-
registerCallbackWhenCacheEmpty
-
registerCallbackWhenCacheEmpty
-
destroy
public void destroy() -
isInputCASPendingReply
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
-
releaseAllCASes
public void releaseAllCASes() -
setName
- Specified by:
setName
in interfaceInProcessCacheMBean
-
getName
- Specified by:
getName
in interfaceInProcessCacheMBean
-
cancelTimers
public void cancelTimers() -
isEmpty
public boolean isEmpty() -
reset
public void reset()- Specified by:
reset
in interfaceInProcessCacheMBean
-
getSize
public int getSize()- Specified by:
getSize
in interfaceInProcessCacheMBean
-
setSize
public void setSize(int i) - Specified by:
setSize
in interfaceInProcessCacheMBean
-
dumpContents
-
remove
-
removeCas
-
getCacheEntriesForEndpoint
-
saveSerializedCAS
-
getSerializedCAS
-
setCasProducer
-
getCasProducer
-
getCasByReference
-
getMessageAccessorByReference
-
getOutOfTypeSystemData
-
addEndpoint
-
getEndpoint
-
removeEndpoint
-
getStartTime
-
entryExists
-
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.OutOfTypeSystemData otsd, String aCasReferenceId) throws AsynchAEException - Throws:
AsynchAEException
-
hasNoSubordinates
-
getTopAncestorEndpoint
- Throws:
Exception
-
getCacheEntryForCAS
public InProcessCache.CacheEntry getCacheEntryForCAS(String aCasReferenceId) throws AsynchAEException - Throws:
AsynchAEException
-