Package org.apache.uima.aae.controller
Interface AnalysisEngineController
- All Superinterfaces:
ControllerLifecycle
- All Known Subinterfaces:
AggregateAnalysisEngineController
,PrimitiveAnalysisEngineController
- All Known Implementing Classes:
AggregateAnalysisEngineController_impl
,AnalysisEngineControllerAdapter
,BaseAnalysisEngineController
,PrimitiveAnalysisEngineController_impl
,UimacppServiceController
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionvoid
addAbortedCasReferenceId
(String aCasReferenceId) void
addInputChannel
(InputChannel anInputChannel) void
addServiceInfo
(ServiceInfo aServiceInfo) void
beginProcess
(int msgType) void
cacheClientEndpoint
(Endpoint anEndpoint) void
void
collectionProcessComplete
(Endpoint anEndpoint) void
void
dropCAS
(org.apache.uima.cas.CAS aCAS) void
void
dumpState
(StringBuffer buffer, String lbl1) void
endProcess
(int msgType) void
long
getCasStatistics
(String aCasReferenceId) org.apache.uima.UimaContext
getChildUimaContext
(String aDelegateEndpointName) long
long
long
getIdleTimeBetweenProcessCalls
(int msgType) int
getIndex()
getInputChannel
(String aQueueName) getKey()
getName()
getReplyInputChannel
(String aDelegateKey) long
getState()
getStats()
long
getTransport
(String aKey) getTransport
(UimaAsContext aContext, String aKey) getUimaMessageListener
(String aDelegateKey) void
handleDelegateLifeCycleEvent
(String anEndpoint, int aDelegateCount) void
incrementDeserializationTime
(long cpuTime) void
incrementSerializationTime
(long cpuTime) void
void
initializeVMTransport
(int parentControllerReplyConsumerCount) boolean
boolean
boolean
boolean
Returns true if the AnalysisEngineController has been (or is in the process of) shutdown.boolean
void
void
void
void
process
(org.apache.uima.cas.CAS aCAS, String anInputCasReferenceId, String aNewCasReferenceId, String newCASProducedBy) void
void
void
registerVmQueueWithJMX
(Object o, String aName) void
releaseNextCas
(String aCasReferenceId) void
saveReplyTime
(long snapshot, String aKey) void
void
sendMetadata
(Endpoint anEndpoint) void
setCasManager
(AsynchAECasManager aCasManager) void
setDeployDescriptor
(String aDeployDescriptor) void
setInputChannel
(InputChannel anInputChannel) void
setOutputChannel
(OutputChannel anOutputChannel) void
Called to set the state of the AnalysisEngineController to STOPPED.void
setUimaEEAdminContext
(UimaEEAdminContext anAdminContext) void
stop()
void
takeAction
(String anAction, String anEndpointName, ErrorContext anErrorContext) Methods inherited from interface org.apache.uima.aae.controller.ControllerLifecycle
addControllerCallbackListener, removeControllerCallbackListener, terminate
-
Field Details
-
CasPoolSize
- See Also:
-
AEInstanceCount
- See Also:
-
-
Method Details
-
sendMetadata
- Throws:
AsynchAEException
-
getControllerLatch
ControllerLatch getControllerLatch() -
setInputChannel
- Throws:
Exception
-
addInputChannel
- Throws:
Exception
-
getServiceEndpointName
String getServiceEndpointName() -
handleDelegateLifeCycleEvent
-
takeAction
-
getInputChannel
InputChannel getInputChannel() -
getInputChannel
-
saveReplyTime
-
getReplyTime
long getReplyTime() -
getStats
Map getStats() -
getChildUimaContext
- Throws:
Exception
-
dropCAS
-
dropCAS
void dropCAS(org.apache.uima.cas.CAS aCAS) -
getInProcessCache
InProcessCache getInProcessCache() -
isPrimitive
boolean isPrimitive() -
getMonitor
Monitor getMonitor() -
getName
String getName() -
getComponentName
String getComponentName() -
collectionProcessComplete
- Throws:
AsynchAEException
-
isTopLevelComponent
boolean isTopLevelComponent() -
initialize
- Throws:
AsynchAEException
-
process
-
process
-
process
-
saveTime
-
getTime
-
getErrorHandlerChain
ErrorHandlerChain getErrorHandlerChain() -
setOutputChannel
- Throws:
Exception
-
getOutputChannel
OutputChannel getOutputChannel() -
setCasManager
-
getCasManagerWrapper
AsynchAECasManager getCasManagerWrapper() -
stop
void stop() -
isStopped
boolean isStopped()Returns true if the AnalysisEngineController has been (or is in the process of) shutdown.- Returns:
- - true if stopped
-
setStopped
void setStopped()Called to set the state of the AnalysisEngineController to STOPPED. This method does not stop input or output channels. -
dropStats
-
setUimaEEAdminContext
-
getUimaEEAdminContext
UimaEEAdminContext getUimaEEAdminContext() -
getJMXDomain
String getJMXDomain() -
getIndex
int getIndex() -
getJmxContext
String getJmxContext() -
getServicePerformance
ServicePerformance getServicePerformance() -
getServiceInfo
ServiceInfo getServiceInfo() -
addServiceInfo
-
getServiceErrors
ServiceErrors getServiceErrors() -
setDeployDescriptor
-
cacheClientEndpoint
-
getClientEndpoint
Endpoint getClientEndpoint() -
getEventListener
EventSubscriber getEventListener() -
getManagementInterface
JmxManagement getManagementInterface() -
notifyListenersWithInitializationStatus
-
getCasStatistics
-
isCasMultiplier
boolean isCasMultiplier() -
releaseNextCas
-
getIdleTime
long getIdleTime() -
beginProcess
void beginProcess(int msgType) -
endProcess
void endProcess(int msgType) -
getIdleTimeBetweenProcessCalls
long getIdleTimeBetweenProcessCalls(int msgType) -
getCpuTime
long getCpuTime() -
getAnalysisTime
long getAnalysisTime() -
incrementSerializationTime
void incrementSerializationTime(long cpuTime) -
incrementDeserializationTime
void incrementDeserializationTime(long cpuTime) -
onInitialize
void onInitialize() -
getUimaMessageListener
-
getTransport
- Throws:
Exception
-
getTransport
- Throws:
Exception
-
initializeVMTransport
- Throws:
Exception
-
getReplyInputChannel
-
getLocalCache
LocalCache getLocalCache() -
registerVmQueueWithJMX
- Throws:
Exception
-
getParentController
AnalysisEngineController getParentController() -
addAbortedCasReferenceId
-
isAwaitingCacheCallbackNotification
boolean isAwaitingCacheCallbackNotification() -
quiesceAndStop
void quiesceAndStop() -
forceTimeoutOnPendingCases
-
changeState
-
getState
BaseAnalysisEngineController.ServiceState getState() -
getDeadClientMap
-
getKey
String getKey() -
dumpState
-