Package org.apache.uima.aae.controller
Interface AggregateAnalysisEngineController
- All Superinterfaces:
AnalysisEngineController
,ControllerLifecycle
- All Known Implementing Classes:
AggregateAnalysisEngineController_impl
-
Field Summary
Fields inherited from interface org.apache.uima.aae.controller.AnalysisEngineController
AEInstanceCount, CasPoolSize
-
Method Summary
Modifier and TypeMethodDescriptionvoid
addMessageOrigin
(String aCasReferenceId, Endpoint anEndpoint) void
changeCollocatedDelegateState
(String delegateKey, BaseAnalysisEngineController.ServiceState state) boolean
continueOnError
(String aCasReferenceId, String aDelegateKey, Exception anException) boolean
delayCasIfDelegateInTimedOutState
(String aCasReferenceId, String aDelegateKey) void
disableDelegates
(List aDelegateList) void
dispatchMetadataRequest
(Endpoint anEndpoint) void
void
enableDelegates
(List aDelegateList) void
org.apache.uima.UimaContext
getChildUimaContext
(String aDelegateEndpointName) getDelegateServiceErrors
(String aDelegateKey) getDelegateServiceInfo
(String aDelegateKey) getDelegateServicePerformance
(String aDelegateKey) getLastDelegateKeyFromFlow
(String anInputCasReferenceId) getMessageOrigin
(String aCasReferenceId) getServicePerformance
(String aDelegateKey) boolean
isDelegateDisabled
(String aDelegateKey) boolean
isDelegateKeyValid
(String anEndpointName) lookupDelegate
(String aDelegateKey) lookUpDelegateKey
(String aDelegateEndpointName) lookUpDelegateKey
(String aDelegateEndpointName, String server) lookUpEndpoint
(String anAnalysisEngineKey, boolean clone) void
mapEndpointsToKeys
(ConcurrentHashMap aDestinationMap) void
mergeTypeSystem
(String aTypeSystem, String fromDestination) void
mergeTypeSystem
(String aTypeSystem, String fromDestination, String fromServer) void
processCollectionCompleteReplyFromDelegate
(String aDelegateKey, boolean sendReply) void
registerChildController
(AnalysisEngineController aChildController, String aDelegateKey) void
removeMessageOrigin
(String aCasReferenceId) boolean
void
retryLastCommand
(int aCommand, Endpoint anEndpoint, String aCasReferenceId) void
retryMetadataRequest
(Endpoint anEndpoint) void
retryProcessCASRequest
(String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache) void
saveStatsFromService
(String aServiceEndpointName, Map aServiceStats) void
void
setCasLoggingDirectory
(String key, String directoryName) void
void
stopCasMultiplier
(Delegate casMultiplier, String aCasReferenceId) void
Methods inherited from interface org.apache.uima.aae.controller.AnalysisEngineController
addAbortedCasReferenceId, addInputChannel, addServiceInfo, beginProcess, cacheClientEndpoint, changeState, collectionProcessComplete, dropCAS, dropCAS, dropStats, dumpState, endProcess, forceTimeoutOnPendingCases, getAnalysisTime, getCasManagerWrapper, getCasStatistics, getClientEndpoint, getComponentName, getControllerLatch, getCpuTime, getDeadClientMap, getErrorHandlerChain, getEventListener, getIdleTime, getIdleTimeBetweenProcessCalls, getIndex, getInProcessCache, getInputChannel, getInputChannel, getJmxContext, getJMXDomain, getKey, getLocalCache, getManagementInterface, getMonitor, getName, getOutputChannel, getParentController, getReplyInputChannel, getReplyTime, getServiceEndpointName, getServiceErrors, getServicePerformance, getState, getStats, getTime, getTransport, getTransport, getUimaEEAdminContext, getUimaMessageListener, handleDelegateLifeCycleEvent, incrementDeserializationTime, incrementSerializationTime, initialize, initializeVMTransport, isAwaitingCacheCallbackNotification, isCasMultiplier, isPrimitive, isStopped, isTopLevelComponent, notifyListenersWithInitializationStatus, onInitialize, process, process, process, quiesceAndStop, registerVmQueueWithJMX, releaseNextCas, saveReplyTime, saveTime, sendMetadata, setCasManager, setDeployDescriptor, setInputChannel, setOutputChannel, setStopped, setUimaEEAdminContext, stop, takeAction
Methods inherited from interface org.apache.uima.aae.controller.ControllerLifecycle
addControllerCallbackListener, removeControllerCallbackListener, terminate
-
Method Details
-
mergeTypeSystem
- Throws:
AsynchAEException
-
mergeTypeSystem
void mergeTypeSystem(String aTypeSystem, String fromDestination, String fromServer) throws AsynchAEException - Throws:
AsynchAEException
-
sendRequestForMetadataToRemoteDelegates
- Throws:
AsynchAEException
-
addMessageOrigin
-
getMessageOrigin
-
removeMessageOrigin
-
processCollectionCompleteReplyFromDelegate
void processCollectionCompleteReplyFromDelegate(String aDelegateKey, boolean sendReply) throws AsynchAEException - Throws:
AsynchAEException
-
isDelegateKeyValid
-
mapEndpointsToKeys
-
lookUpEndpoint
- Throws:
AsynchAEException
-
dispatchMetadataRequest
- Throws:
AsynchAEException
-
retryLastCommand
-
retryMetadataRequest
- Throws:
AsynchAEException
-
lookUpDelegateKey
-
lookUpDelegateKey
-
getChildUimaContext
- Specified by:
getChildUimaContext
in interfaceAnalysisEngineController
- Throws:
Exception
-
retryProcessCASRequest
void retryProcessCASRequest(String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache) throws AsynchAEException - Throws:
AsynchAEException
-
enableDelegates
- Throws:
AsynchAEException
-
disableDelegates
- Throws:
AsynchAEException
-
continueOnError
boolean continueOnError(String aCasReferenceId, String aDelegateKey, Exception anException) throws AsynchAEException - Throws:
AsynchAEException
-
dropFlow
-
isDelegateDisabled
-
getLastDelegateKeyFromFlow
-
registerChildController
void registerChildController(AnalysisEngineController aChildController, String aDelegateKey) throws Exception - Throws:
Exception
-
saveStatsFromService
-
getDelegateStats
Map getDelegateStats() -
getServiceInfo
AggregateServiceInfo getServiceInfo()- Specified by:
getServiceInfo
in interfaceAnalysisEngineController
-
getDelegateServicePerformance
-
getDelegateServiceInfo
-
getDelegateServiceErrors
-
stopTimers
void stopTimers() -
requestForMetaSentToRemotes
boolean requestForMetaSentToRemotes() -
setRequestForMetaSentToRemotes
void setRequestForMetaSentToRemotes() -
getDestinations
Map getDestinations() -
getServicePerformance
-
finalStep
-
lookupDelegate
-
delayCasIfDelegateInTimedOutState
boolean delayCasIfDelegateInTimedOutState(String aCasReferenceId, String aDelegateKey) throws AsynchAEException - Throws:
AsynchAEException
-
getChildControllerList
List getChildControllerList() -
stopCasMultiplier
-
setCasLoggingDirectory
-
changeCollocatedDelegateState
void changeCollocatedDelegateState(String delegateKey, BaseAnalysisEngineController.ServiceState state) throws Exception - Throws:
Exception
-