public interface AnalysisEngineController extends ControllerLifecycle
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
AEInstanceCount |
static java.lang.String |
CasPoolSize |
Modifier and Type | Method and Description |
---|---|
void |
addAbortedCasReferenceId(java.lang.String aCasReferenceId) |
void |
addInputChannel(InputChannel anInputChannel) |
void |
addServiceInfo(ServiceInfo aServiceInfo) |
void |
beginProcess(int msgType) |
void |
cacheClientEndpoint(Endpoint anEndpoint) |
void |
changeState(BaseAnalysisEngineController.ServiceState state) |
void |
collectionProcessComplete(Endpoint anEndpoint) |
void |
dropCAS(org.apache.uima.cas.CAS aCAS) |
void |
dropCAS(java.lang.String aCasReferenceId,
boolean dropCacheEntry) |
void |
dropStats(java.lang.String aCasReferenceId,
java.lang.String anEndpointName) |
void |
dumpState(java.lang.StringBuffer buffer,
java.lang.String lbl1) |
void |
endProcess(int msgType) |
void |
forceTimeoutOnPendingCases(java.lang.String key) |
long |
getAnalysisTime() |
AsynchAECasManager |
getCasManagerWrapper() |
ServicePerformance |
getCasStatistics(java.lang.String aCasReferenceId) |
org.apache.uima.UimaContext |
getChildUimaContext(java.lang.String aDelegateEndpointName) |
Endpoint |
getClientEndpoint() |
java.lang.String |
getComponentName() |
ControllerLatch |
getControllerLatch() |
long |
getCpuTime() |
java.util.Map<java.lang.String,java.lang.String> |
getDeadClientMap() |
ErrorHandlerChain |
getErrorHandlerChain() |
EventSubscriber |
getEventListener() |
long |
getIdleTime() |
long |
getIdleTimeBetweenProcessCalls(int msgType) |
int |
getIndex() |
InProcessCache |
getInProcessCache() |
InputChannel |
getInputChannel() |
InputChannel |
getInputChannel(java.lang.String aQueueName) |
java.lang.String |
getJmxContext() |
java.lang.String |
getJMXDomain() |
java.lang.String |
getKey() |
LocalCache |
getLocalCache() |
JmxManagement |
getManagementInterface() |
Monitor |
getMonitor() |
java.lang.String |
getName() |
OutputChannel |
getOutputChannel() |
AnalysisEngineController |
getParentController() |
InputChannel |
getReplyInputChannel(java.lang.String aDelegateKey) |
long |
getReplyTime() |
java.lang.String |
getServiceEndpointName() |
ServiceErrors |
getServiceErrors() |
ServiceInfo |
getServiceInfo() |
ServicePerformance |
getServicePerformance() |
BaseAnalysisEngineController.ServiceState |
getState() |
java.util.Map |
getStats() |
long |
getTime(java.lang.String aCasReferenceId,
java.lang.String anEndpointName) |
UimaTransport |
getTransport(java.lang.String aKey) |
UimaTransport |
getTransport(UimaAsContext aContext,
java.lang.String aKey) |
UimaEEAdminContext |
getUimaEEAdminContext() |
UimaMessageListener |
getUimaMessageListener(java.lang.String aDelegateKey) |
void |
handleDelegateLifeCycleEvent(java.lang.String anEndpoint,
int aDelegateCount) |
void |
incrementDeserializationTime(long cpuTime) |
void |
incrementSerializationTime(long cpuTime) |
void |
initialize() |
void |
initializeVMTransport(int parentControllerReplyConsumerCount) |
boolean |
isAwaitingCacheCallbackNotification() |
boolean |
isCasMultiplier() |
boolean |
isPrimitive() |
boolean |
isStopped()
Returns true if the AnalysisEngineController has been (or is in the process of) shutdown.
|
boolean |
isTopLevelComponent() |
void |
notifyListenersWithInitializationStatus(java.lang.Exception e) |
void |
onInitialize() |
void |
process(org.apache.uima.cas.CAS aCas,
java.lang.String aCasId) |
void |
process(org.apache.uima.cas.CAS aCAS,
java.lang.String aCasReferenceId,
Endpoint anEndpoint) |
void |
process(org.apache.uima.cas.CAS aCAS,
java.lang.String anInputCasReferenceId,
java.lang.String aNewCasReferenceId,
java.lang.String newCASProducedBy) |
void |
quiesceAndStop() |
void |
registerVmQueueWithJMX(java.lang.Object o,
java.lang.String aName) |
void |
releaseNextCas(java.lang.String aCasReferenceId) |
void |
saveReplyTime(long snapshot,
java.lang.String aKey) |
void |
saveTime(long anArrivalTime,
java.lang.String aCasReferenceId,
java.lang.String anEndpointName) |
void |
sendMetadata(Endpoint anEndpoint) |
void |
setCasManager(AsynchAECasManager aCasManager) |
void |
setDeployDescriptor(java.lang.String aDeployDescriptor) |
void |
setInputChannel(InputChannel anInputChannel) |
void |
setOutputChannel(OutputChannel anOutputChannel) |
void |
setStopped()
Called to set the state of the AnalysisEngineController to STOPPED.
|
void |
setUimaEEAdminContext(UimaEEAdminContext anAdminContext) |
void |
stop() |
void |
takeAction(java.lang.String anAction,
java.lang.String anEndpointName,
ErrorContext anErrorContext) |
addControllerCallbackListener, removeControllerCallbackListener, terminate
static final java.lang.String CasPoolSize
static final java.lang.String AEInstanceCount
void sendMetadata(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
ControllerLatch getControllerLatch()
void setInputChannel(InputChannel anInputChannel) throws java.lang.Exception
java.lang.Exception
void addInputChannel(InputChannel anInputChannel) throws java.lang.Exception
java.lang.Exception
java.lang.String getServiceEndpointName()
void handleDelegateLifeCycleEvent(java.lang.String anEndpoint, int aDelegateCount)
void takeAction(java.lang.String anAction, java.lang.String anEndpointName, ErrorContext anErrorContext)
InputChannel getInputChannel()
InputChannel getInputChannel(java.lang.String aQueueName)
void saveReplyTime(long snapshot, java.lang.String aKey)
long getReplyTime()
java.util.Map getStats()
org.apache.uima.UimaContext getChildUimaContext(java.lang.String aDelegateEndpointName) throws java.lang.Exception
java.lang.Exception
void dropCAS(java.lang.String aCasReferenceId, boolean dropCacheEntry)
void dropCAS(org.apache.uima.cas.CAS aCAS)
InProcessCache getInProcessCache()
boolean isPrimitive()
Monitor getMonitor()
java.lang.String getName()
java.lang.String getComponentName()
void collectionProcessComplete(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
boolean isTopLevelComponent()
void initialize() throws AsynchAEException
AsynchAEException
void process(org.apache.uima.cas.CAS aCas, java.lang.String aCasId)
void process(org.apache.uima.cas.CAS aCAS, java.lang.String anInputCasReferenceId, java.lang.String aNewCasReferenceId, java.lang.String newCASProducedBy)
void process(org.apache.uima.cas.CAS aCAS, java.lang.String aCasReferenceId, Endpoint anEndpoint)
void saveTime(long anArrivalTime, java.lang.String aCasReferenceId, java.lang.String anEndpointName)
long getTime(java.lang.String aCasReferenceId, java.lang.String anEndpointName)
ErrorHandlerChain getErrorHandlerChain()
void setOutputChannel(OutputChannel anOutputChannel) throws java.lang.Exception
java.lang.Exception
OutputChannel getOutputChannel()
void setCasManager(AsynchAECasManager aCasManager)
AsynchAECasManager getCasManagerWrapper()
void stop()
boolean isStopped()
void setStopped()
void dropStats(java.lang.String aCasReferenceId, java.lang.String anEndpointName)
void setUimaEEAdminContext(UimaEEAdminContext anAdminContext)
UimaEEAdminContext getUimaEEAdminContext()
java.lang.String getJMXDomain()
int getIndex()
java.lang.String getJmxContext()
ServicePerformance getServicePerformance()
ServiceInfo getServiceInfo()
void addServiceInfo(ServiceInfo aServiceInfo)
ServiceErrors getServiceErrors()
void setDeployDescriptor(java.lang.String aDeployDescriptor)
void cacheClientEndpoint(Endpoint anEndpoint)
Endpoint getClientEndpoint()
EventSubscriber getEventListener()
JmxManagement getManagementInterface()
void notifyListenersWithInitializationStatus(java.lang.Exception e)
ServicePerformance getCasStatistics(java.lang.String aCasReferenceId)
boolean isCasMultiplier()
void releaseNextCas(java.lang.String aCasReferenceId)
long getIdleTime()
void beginProcess(int msgType)
void endProcess(int msgType)
long getIdleTimeBetweenProcessCalls(int msgType)
long getCpuTime()
long getAnalysisTime()
void incrementSerializationTime(long cpuTime)
void incrementDeserializationTime(long cpuTime)
void onInitialize()
UimaMessageListener getUimaMessageListener(java.lang.String aDelegateKey)
UimaTransport getTransport(UimaAsContext aContext, java.lang.String aKey) throws java.lang.Exception
java.lang.Exception
UimaTransport getTransport(java.lang.String aKey) throws java.lang.Exception
java.lang.Exception
void initializeVMTransport(int parentControllerReplyConsumerCount) throws java.lang.Exception
java.lang.Exception
InputChannel getReplyInputChannel(java.lang.String aDelegateKey)
LocalCache getLocalCache()
void registerVmQueueWithJMX(java.lang.Object o, java.lang.String aName) throws java.lang.Exception
java.lang.Exception
AnalysisEngineController getParentController()
void addAbortedCasReferenceId(java.lang.String aCasReferenceId)
boolean isAwaitingCacheCallbackNotification()
void quiesceAndStop()
void forceTimeoutOnPendingCases(java.lang.String key)
void changeState(BaseAnalysisEngineController.ServiceState state)
BaseAnalysisEngineController.ServiceState getState()
java.util.Map<java.lang.String,java.lang.String> getDeadClientMap()
java.lang.String getKey()
void dumpState(java.lang.StringBuffer buffer, java.lang.String lbl1)
Copyright © 2012. All Rights Reserved.