public interface AggregateAnalysisEngineController extends AnalysisEngineController
AEInstanceCount, CasPoolSize
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
addControllerCallbackListener, removeControllerCallbackListener, terminate
void mergeTypeSystem(String aTypeSystem, String fromDestination) throws AsynchAEException
AsynchAEException
void mergeTypeSystem(String aTypeSystem, String fromDestination, String fromServer) throws AsynchAEException
AsynchAEException
void sendRequestForMetadataToRemoteDelegates() throws AsynchAEException
AsynchAEException
void removeMessageOrigin(String aCasReferenceId)
void processCollectionCompleteReplyFromDelegate(String aDelegateKey, boolean sendReply) throws AsynchAEException
AsynchAEException
boolean isDelegateKeyValid(String anEndpointName)
void mapEndpointsToKeys(ConcurrentHashMap aDestinationMap)
Endpoint lookUpEndpoint(String anAnalysisEngineKey, boolean clone) throws AsynchAEException
AsynchAEException
void dispatchMetadataRequest(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
void retryMetadataRequest(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
org.apache.uima.UimaContext getChildUimaContext(String aDelegateEndpointName) throws Exception
getChildUimaContext
in interface AnalysisEngineController
Exception
void retryProcessCASRequest(String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache) throws AsynchAEException
AsynchAEException
void enableDelegates(List aDelegateList) throws AsynchAEException
AsynchAEException
void disableDelegates(List aDelegateList) throws AsynchAEException
AsynchAEException
boolean continueOnError(String aCasReferenceId, String aDelegateKey, Exception anException) throws AsynchAEException
AsynchAEException
void dropFlow(String aCasReferenceId, boolean dropFlow)
boolean isDelegateDisabled(String aDelegateKey)
void registerChildController(AnalysisEngineController aChildController, String aDelegateKey) throws Exception
Exception
Map getDelegateStats()
AggregateServiceInfo getServiceInfo()
getServiceInfo
in interface AnalysisEngineController
ServicePerformance getDelegateServicePerformance(String aDelegateKey)
PrimitiveServiceInfo getDelegateServiceInfo(String aDelegateKey)
ServiceErrors getDelegateServiceErrors(String aDelegateKey)
void stopTimers()
boolean requestForMetaSentToRemotes()
void setRequestForMetaSentToRemotes()
Map getDestinations()
ServicePerformance getServicePerformance(String aDelegateKey)
void finalStep(org.apache.uima.flow.FinalStep aStep, String aCasReferenceId)
boolean delayCasIfDelegateInTimedOutState(String aCasReferenceId, String aDelegateKey) throws AsynchAEException
AsynchAEException
List getChildControllerList()
void changeCollocatedDelegateState(String delegateKey, BaseAnalysisEngineController.ServiceState state) throws Exception
Exception
Copyright © 2017. All rights reserved.