public class InProcessCache extends Object implements InProcessCacheMBean
Modifier and Type | Class and Description |
---|---|
static class |
InProcessCache.CacheEntry |
Modifier and Type | Field and Description |
---|---|
static int |
NotifyWhenRegistering |
Constructor and Description |
---|
InProcessCache() |
Modifier and Type | Method and Description |
---|---|
void |
addEndpoint(Endpoint anEndpoint,
String aCasReferenceId) |
void |
cancelTimers() |
void |
destroy() |
void |
dumpContents(String aControllerName) |
boolean |
entryExists(String aCasReferenceId) |
InProcessCache.CacheEntry[] |
getCacheEntriesForEndpoint(String anEndpointName) |
InProcessCache.CacheEntry |
getCacheEntryForCAS(String aCasReferenceId) |
org.apache.uima.cas.CAS |
getCasByReference(String aCasReferenceId) |
String |
getCasProducer(String aCasReferenceId) |
Endpoint |
getEndpoint(String anEndpointName,
String aCasReferenceId) |
MessageContext |
getMessageAccessorByReference(String aCasReferenceId) |
String |
getName() |
org.apache.uima.cas.impl.OutOfTypeSystemData |
getOutOfTypeSystemData(String aCasReferenceId) |
String |
getSerializedCAS(String aCasReferenceId) |
int |
getSize() |
long |
getStartTime(String aCasReferenceId) |
Endpoint |
getTopAncestorEndpoint(InProcessCache.CacheEntry anEntry) |
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) |
InProcessCache.CacheEntry |
register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.OutOfTypeSystemData otsd) |
InProcessCache.CacheEntry |
register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.OutOfTypeSystemData otsd,
String aCasReferenceId) |
InProcessCache.CacheEntry |
register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.XmiSerializationSharedData sharedData) |
InProcessCache.CacheEntry |
register(org.apache.uima.cas.CAS aCAS,
MessageContext aMessageContext,
org.apache.uima.cas.impl.XmiSerializationSharedData sharedData,
String aCasReferenceId) |
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) |
void |
registerCallbackWhenCacheEmpty(EventSubscriber aController) |
void |
registerCallbackWhenCacheEmpty(EventSubscriber aController,
int notification) |
void |
releaseAllCASes() |
void |
releaseCASesProducedFromInputCAS(String anInputCASReferenceId) |
void |
remove(String aCasReferenceId) |
void |
removeCas(String aCasReferenceId) |
void |
removeEndpoint(String anEndpointName,
String aCasReferenceId) |
void |
reset() |
void |
saveSerializedCAS(String aCasReferenceId,
String anXCAS) |
void |
setCasProducer(String aCasReferenceId,
String aCasProducerKey) |
void |
setName(String aName) |
void |
setSize(int i) |
public static final int NotifyWhenRegistering
public void registerCallbackWhenCacheEmpty(EventSubscriber aController)
public void registerCallbackWhenCacheEmpty(EventSubscriber aController, int notification)
public void destroy()
public boolean isInputCASPendingReply(String anInputCASReferenceId) throws Exception
anInputCASReferenceId
- Exception
public boolean producedCASesStillInPlay(String anInputCASReferenceId, String aSubordinateCASReferenceId) throws Exception
Exception
public void releaseCASesProducedFromInputCAS(String anInputCASReferenceId)
public void releaseAllCASes()
public void setName(String aName)
setName
in interface InProcessCacheMBean
public String getName()
getName
in interface InProcessCacheMBean
public void cancelTimers()
public boolean isEmpty()
public void reset()
reset
in interface InProcessCacheMBean
public int getSize()
getSize
in interface InProcessCacheMBean
public void setSize(int i)
setSize
in interface InProcessCacheMBean
public void dumpContents(String aControllerName)
public void remove(String aCasReferenceId)
public void removeCas(String aCasReferenceId)
public InProcessCache.CacheEntry[] getCacheEntriesForEndpoint(String anEndpointName)
public org.apache.uima.cas.CAS getCasByReference(String aCasReferenceId)
public MessageContext getMessageAccessorByReference(String aCasReferenceId)
public org.apache.uima.cas.impl.OutOfTypeSystemData getOutOfTypeSystemData(String aCasReferenceId)
public long getStartTime(String aCasReferenceId)
public boolean entryExists(String aCasReferenceId)
public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.OutOfTypeSystemData otsd) throws AsynchAEException
AsynchAEException
public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.XmiSerializationSharedData sharedData) throws AsynchAEException
AsynchAEException
public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.OutOfTypeSystemData otsd, String aCasReferenceId) throws AsynchAEException
AsynchAEException
public InProcessCache.CacheEntry register(org.apache.uima.cas.CAS aCAS, MessageContext aMessageContext, org.apache.uima.cas.impl.XmiSerializationSharedData sharedData, String aCasReferenceId) throws AsynchAEException
AsynchAEException
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
AsynchAEException
public boolean hasNoSubordinates(String aCasReferenceId)
public Endpoint getTopAncestorEndpoint(InProcessCache.CacheEntry anEntry) throws Exception
Exception
public InProcessCache.CacheEntry getCacheEntryForCAS(String aCasReferenceId) throws AsynchAEException
AsynchAEException
Copyright © 2016. All rights reserved.